kafka是可以保证同一个分区里面的消息写入是有序的。也就是说，如果生产者按照一定的顺序发送消息，broker就会按照这个消息顺序来将他们写入分区，消费者也会按照一定的顺序将他们写入分区，消费者也会按照同样的顺序读取它们。 在某些情况下，数据的顺序是很重要的，例如，在一个账户存入100元再取出来 和 ...
分类：
其他好文 时间：
2020-04-03 15:05:39
阅读次数：
225
@ "TOC" 第一 、先上效果图 c51程序在第四步，app程序在第六步 第二、原理讲解 原理简述 ：利用发布订阅模式。第一步，先STC89c51获取各种传感器数值，第二步，新建主题，然后c51往这个主题发送消息，第三步。app inventor 订阅这个主题，因为app inventor 制作的 ...
分类：
移动开发 时间：
2020-04-03 01:03:43
阅读次数：
96
通过命令行工具(kafka-console-producer.sh和kafka-console-consumer.sh)是能够相互通信的，producer发布的信息consumer能够接收到。 但是java通过kafka-client的API写的代码始终不能跟kafka通信：java produce ...
分类：
编程语言 时间：
2020-04-02 10:24:08
阅读次数：
530
什么是WebSocket？ HTML5新增协议，它的目的在浏览器和服务器之间建立一个不受限的双向实时通信的通道。比如，服务器可以任意时刻发送消息给浏览器。它是基于TCP，先通过HTTP/HTTPS协议发起一条特殊的HTTP请求进行握手后创建一个用于交换数据的TCP连接。 它的优势是什么? 浏览器和服 ...
分类：
Web程序 时间：
2020-04-02 01:33:09
阅读次数：
100
各位读者，大家好！ 下来我给大家带来我珍藏多年的珍品。 java自动化工具类，包含鼠标单击、双击、右击、按键、组合按键、剪贴板、提示框、提示音、截屏、屏幕大小、坐标等等。 基本上涵盖了所有的人为行为，比如用这个工具我们可以实现自动化定时截屏、自动化发送消息等等。 想想是不是很炫，哈哈哈。作为一个程序 ...
分类：
编程语言 时间：
2020-04-01 19:48:26
阅读次数：
394
"""TCP-IP协议族：应用层：应用程序自身定义的协议，比如p = 100、HTTP也属于应用层比如说浏览器传输层：TCP、UDP（原始套接字可以直接从应用层到IP，可以伪装别人的IP发送消息）网络层：IP、ICMP（cmd通过ping命令直接查看网络是否正常不通过传输层，应用层→ICMP→IP） ...
分类：
其他好文 时间：
2020-03-31 01:37:02
阅读次数：
235
因为订阅号没有客服消息,所以只能在用户发送消息以后,进行被动的回复。而服务号可以通过客服消息主动给用户发消息,下面我就介绍一下这个功能怎么使用。 客服消息主要是向公众号服务器发送HTTPS请求,所以这部分的内容可以使用PostMan等工具进行测试和验证。那么下面就开始吧。 1. 获取AccessTo ...
分类：
微信 时间：
2020-03-30 09:41:47
阅读次数：
108
Kafka-硬件的选择 磁盘吞吐量（重要，影响生产者） 生产者客户端的性能直接受到服务器端磁盘吞吐量的影响。 生产者生成的消息必须被提交到服务器保存，大多数客户端在发送消息后会一直等待，直到至少一个服务器确认消息已经成功提交为止。 磁盘写入速度越快，生成消息的延迟就越低。 磁盘容量（制约集群规模） ...
分类：
其他好文 时间：
2020-03-29 13:00:28
阅读次数：
102
简单工厂模式/* 简单工厂模式：完全冗余生产，容易混乱 通过一个工厂内实现所有的部件发送消息 */public class FactorySimple { //简单工厂模式：内部无该具体类的属性 public void sendMSG(String type,String message) { if... ...
分类：
其他好文 时间：
2020-03-25 19:28:46
阅读次数：
95
在上一节五分钟完成 ABP vNext 通讯录 App 开发 中，我们用完成了通讯录 App 的基础开发。这本章节，我们会给通讯录 App 安装私信模块，使不同用户能够通过相互发送消息，并接收新私信的通知。在章节的最后，笔者将演示模块的“改装”，实现禁止用户发私信给自己的定制化需求。什么是“模块”？ ...
分类：
其他好文 时间：
2020-03-23 09:22:44
阅读次数：
80
