首先解释下consumeQueue，由于commit-log是根据消息先后存储的，而我们消费的时候是根据topic来筛选的，所以需要一个队列根据topic来划分，所以consumeQueue就是干这个事情的。而indexfile顾名思义就是索引文件，用来做单纯查询的。 private final C ...
分类：
其他好文 时间：
2019-12-08 22:51:24
阅读次数：
69
5. 分布式事务解决方案之可靠消息最终一致性 5.1. 什么是可靠消息最终一致性事务 可靠消息最终一致性方案是指当事务发起执行完全本地事务后并发出一条消息，事务参与方（消息消费者）一定能够接收消息并处理事务成功，此方案强调的是只要消息发给事务参与方最终事务要达到一致。此方案是利用消息中间件完成，如下 ...
分类：
其他好文 时间：
2019-11-28 22:54:21
阅读次数：
73
Kafka的结构与RabbitMQ类似，消息生产者向Kafka服务器发送消息，Kafka接收消息后，再投递给消费者。
生产者的消费会被发送到Topic中，Topic中保存着各类数据，每一条数据都使用键、值进行保存。
每一个Topic中都包含一个或多个物理分区（Partition），分区维护着消息... ...
分类：
编程语言 时间：
2019-11-22 23:28:34
阅读次数：
128
https://www.iteye.com/blog/tuposky-2017429 前面两章已经介绍了如何接入微信公众平台，这一章说说消息的接收和发送 可以先了解公众平台的消息api接口（接收消息，发送消息） http://mp.weixin.qq.com/wiki/index.php 接收消息 ...
分类：
微信 时间：
2019-11-21 13:57:10
阅读次数：
119
实例一、 server： #socket套接字（IP + 端口号）（qq，wechat 发送接收消息依靠socket模块）,cs架构import socketserver = socket.socket() #实例化出一个socket对象,默认tcp/ip协议server.bind(('127.0. ...
分类：
编程语言 时间：
2019-11-04 10:03:36
阅读次数：
81
Redis发布订阅（pub/sub）是一种消息通讯模式，发送者（pub）发送消息，订阅者（sub）接收消息。 下图展示渠道channel1，及订阅这个渠道的三个客户端client2，client5，client1之间的关系： 当有新消息通过PUBLISH命令发送到渠道channel1时，这个消息就会 ...
分类：
其他好文 时间：
2019-10-25 09:31:29
阅读次数：
66
#TCP协议实现（发送消息的顺序无要求）（以conn为对象发送和接收消息）（字节流） #-------serve层 import socket import time sk=socket.socket() sk.bind(('10.70.2.143',8080)) #1.服务器地址 2.服务器端口，... ...
分类：
其他好文 时间：
2019-10-22 12:56:40
阅读次数：
88
redis官方网址：https://redis.io/ redis教程网址：https://www.runoob.com/redis/redis-pub-sub.html 一．官方描述 Redis 发布订阅（pub/sub）是一种消息通信模式，发送者发送消息，订阅者接收消息 Redis 可以订阅任意 ...
分类：
其他好文 时间：
2019-10-11 12:22:59
阅读次数：
94
一、发布订阅 Redis 发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。 Redis 客户端可以订阅任意数量的频道。 下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 ...
分类：
其他好文 时间：
2019-10-06 00:51:53
阅读次数：
107
