1.kafka架构 kafka处理消息大概流程 + 生产者发送消息给kafka服务器 + 消费者从kafka服务器（broker）读取消息 + kafka服务器依靠zookeeper集群进行服务协调管理 2.kafka基本术语 + message （消息） 生产消费的基本单位。 + topic（主题 ...
分类：
其他好文 时间：
2019-09-06 01:45:41
阅读次数：
121
1.pom文件引入Kafka依赖（我用的版本是2.2.2.RELEASE） 2.编写Kafka sender工具类 3.在需要发送消息的地方，调用KafkaSender的send方法 测试一下： ...
分类：
其他好文 时间：
2019-09-03 14:58:28
阅读次数：
104
1.生产者： 生产者发送消息到broker，有三种确认方式（request.required.acks）acks = 0: producer不会等待broker（leader）发送ack 。因为发送消息网络超时或broker crash(1.Partition的Leader还没有commit消息 2 ...
分类：
其他好文 时间：
2019-09-03 00:10:47
阅读次数：
141
react+react-native+react-navigation+react-redux+react-native-swiper+rnPop等技术开发仿微信聊天室RN_ChatRoom，实现了app全屏启动页、popupWindow弹窗菜单、消息触摸列表、发送消息、表情(动图)，图片预览，拍摄... ...
分类：
微信 时间：
2019-09-01 11:03:05
阅读次数：
1057
1. 不使用Exchange交换机（默认交换机） 工具类 a. simple简单模式：一个生产者发送消息到队列中由一个消费者接收。 b. work工作队列模式：一个生产者发送消息到队列中可由多个消费者接收；多个消费者之间消息是竞争接收。 2. 使用Exchange交换机；订阅模式（广播fanout， ...
分类：
其他好文 时间：
2019-08-31 21:25:47
阅读次数：
76
Redis入门（七）——Redis发布订阅 目录： Redis发布订阅简介 Redis发布订阅命令 1.Redis发布订阅简介 Redis 发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。 Redis 客户端可以订阅任意数量的频道。 下图展示了频道 ...
分类：
其他好文 时间：
2019-08-31 19:29:31
阅读次数：
73
import socket def send_msg(udp_socket): """发送消息""" # 发数据 # 获取要发送的内容 send_data = input("请输入传递的信息") dest_ip = input("请输入对方的ip；") dest_port = int(input("... ...
分类：
其他好文 时间：
2019-08-31 19:18:20
阅读次数：
54
1, 生产者服务： maven: 定义队列，交换机，并且绑定队列和交换机，同时注入到spring 中 conifg 的上一层就是producer: service 发送消息服务： application.yml: 2,消费者服务： 邮件消费者： 信息消费者： application.yml ...
分类：
编程语言 时间：
2019-08-30 18:40:01
阅读次数：
72
RabbitMQ 是什么? 消息中间件 作用? 用于分布式项目中的模块解耦 用法? 创建队列 创建消息工厂并设置 (生产者额外步骤 : 创建消息) 创建连接,通道 声明队列 生产者 : 发送消息,先关闭通道,再关闭连接 ; 消费者 : 监听队列 交换机类型? fanout, routing互补hea ...
分类：
其他好文 时间：
2019-08-29 16:25:47
阅读次数：
124
QQ聊天机器人 前几日，看到杂志上有一篇关于开发QQ聊天机器人的文章。谈到了对QQ循环发送消息内容，感觉倒也很好玩，于是拿起Delphi开始了我的QQ聊天机器人之路。 首先要明白自己要做什么，大家都用过QQ，知道给别人发送消息的整个过程吧！要实现循环发送消息的功能该有以下几个条件： 1.必须是在聊天 ...
