KafkaProducer 创建一个 KafkaThread 来运行 Sender.run 方法。 1. 发送消息的入口在 KafkaProducer#doSend 中，但其实是把消息加入到 batches 中： kafka 生产者是按 batch 发送消息，RecordAccumulator 类有 ...
分类：
其他好文 时间：
2019-10-01 13:45:37
阅读次数：
73
提前发现更多精彩内容，请访问 "个人博客" 提前发现更多精彩内容，请访问 "个人博客" 提前发现更多精彩内容，请访问 "个人博客" 写在前面 在 "可见性有序性，Happens before来搞定" 文章中，happens before 的原则之一: volatile变量规则 对一个 volatil ...
分类：
其他好文 时间：
2019-09-30 09:17:27
阅读次数：
87
发布订阅： 发布者不是计划发送消息给特定的接收者（订阅者），而是发布的消息分到不同的频道，不需要知道什么样的订阅者订阅 订阅者对一个或多个频道感兴趣，只需接收感兴趣的消息，不需要知道什么样的发布者发布的 发布者和订阅者的解耦合可以带来更大的扩展性和更加动态的网络拓扑 客户端发到频道的消息，将会被推送 ...
分类：
其他好文 时间：
2019-09-28 20:25:40
阅读次数：
81
##什么是RunTime机制 oc在编译的时是不知道调用哪个函数，运行时找不到就报错 C语言在编译的时候就知道调用哪个方法[p eat]消息机制 任何方法调用 本质都是发送消息[p performSelector:@selector()] #import 倒入运行时框架运行时发送消息 谁做事情就去调... ...
分类：
其他好文 时间：
2019-09-28 10:54:06
阅读次数：
92
JMS介绍 JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。 ...
分类：
其他好文 时间：
2019-09-26 13:22:32
阅读次数：
132
当我们使用Spring Boot+websocket进行前后端进行通信时，我们需要注意：服务器可以随时向客户端发送消息。默认的情况下，不保证：服务器发送的消息与到达客户端的消息的顺序是一致的。可能先发送的消息后到，后发送的消息先到。（注意：两个消息发送的时间差不多，不能相差太多，不然就是顺序的了。一 ...
分类：
编程语言 时间：
2019-09-24 22:48:50
阅读次数：
127
使用python操作kafka目前比较常用的库是kafka python库 安装kafka python 生产者 producer_test.py 执行此程序，它没有输出！这个是正常的 消费者 执行此程序，此时会hold住，因为它在等待生产者发送消息！ 再次执行生产者，此时会输出： ...
分类：
编程语言 时间：
2019-09-24 17:57:52
阅读次数：
106
一、消息中间件概述 什么是消息中间件 发送者将消息发送给消息服务器，消息服务器将消感存放在若千队列中，在合适的时候再将消息转发给接收者。 这种模式下，发送和接收是异步的，发送者无需等待; 二者的生命周期未必相同: 发送消息的时候接收者不一定运行，接收消息的时候发送者也不一定运行;一对多通信: 对于一 ...
分类：
其他好文 时间：
2019-09-22 22:04:00
阅读次数：
129
WebChat WEB微信 a、访问页面出现二维码 b、长轮询监听是否已经扫码并且点击确认 c、如何进行会话保持 d、如何获取用户列表 e、如何发送消息(接收消息) HTTP是短链接，客户端连接服务端(没法主动建立连接被动的)，一连是无状态，连上了是断开的 ...
分类：
Web程序 时间：
2019-09-21 21:06:41
阅读次数：
80
1.登录redis 2.认证 3.订阅1000这个消息 4.给1000发送消息 ...
分类：
其他好文 时间：
2019-09-19 12:18:38
阅读次数：
70
