kafka概念　　Topic：消息根据Topic进行归类，可以理解为一个队里。　　Producer：消息生产者，就是向kafkabroker发消息的客户端。　　Consumer：消息消费者，向kafkabroker取消息的客户端。　　broker：每个kafka实例(server)，一台kafka服务器就是一个broker，一个集群

  最近在关注云风大神基于CLua写的Skynet网络框架！采用单进程多线程的Actor并发模型，每个Actor都可以理解成一个服务（协程），服务之间的通信也是采用消息传递的机制与golang、erlang很像。    但是由于大神们的境界太高并且手册、文档较少，所以对初学者来说确实有点难入门。基本只能在目录下的examples与test目录下看实

MQ消息中间件，面试能问些什么？为什么使用消息队列？消息队列的优点和缺点？kafka、activemq、rabbitmq、rocketmq都有什么优缺点？面试官角度分析：（1）你知不知道你们系统里为什么要用消息队列这个东西？（2）既然用了消息队列这个东西，你知不知道用了有什么好处？（3

背景在实际使用过程，会遇到这么些情况：生产者发送的消息数量与消费者接收的消息数量不一致。例如生产者向rabbitmq投递了100条消息，消费者只从队列中接收到了80条消息，并且当前队列中已经没有任何消息。要定位这个问题，通常是分段来定位，一方面统计生产者到底发送了多少消息，一方面统计有多少消息是正确路由到

0x00消息控制器消息控制器，主要作用就是为每个模块提供消息处理的入口.这里的消息不仅仅是协议，还有内部指令，事件等等逻辑入口，这也是为了响应线程模型作出的一种支撑，只要入口在此消息控制器内，那必然走期望的线程调度。@Controller用于标识一个类为当前模块的消息控制器入口.@Controller(threadGroup

1、场景作用削峰填谷，异步解耦。2、如何保证消息不被重复消费呢？这个问题可以换个思路，保证消息重复消费，其实是保证程序的幂等性。无论消息如何重复，程序运行的结果是一致的。比如消费消息后做数据库插入操作，为了防止消息重复消费，可以在插入前先查询一下有没有对应的数据。3、怎么保证从消息队列里拿到的数据按顺序执

1、引言消息是互联网信息的一种表现形式，是人利用计算机进行信息传递的有效载体，比如即时通讯网坛友最熟悉的即时通讯消息就是其具体的表现形式之一。消息从发送者到接收者的典型传递方式有两种：1）一种我们可以称为即时消息：即消息从一端发出后（消息发送者）立即就可以达到另一端（消息接收者），这种方式的具体实现就是平时最常见的IM聊天消息；

客户端确保消息同步的准确性主要依赖于以下几个关键技术和策略：全局唯一的消息ID生成策略：为了保证消息可以通过ID进行识别和排重，IM系统采用全局唯一的消息ID生成策略。这种策略可以确保每条消息都有一个唯一的标识符，从而在消息的发送和接收过程中避免重复。客户

如果用户不在线，融云的推送通知会按照以下方式处理：离线消息推送：当用户不在线时，融云会将收到的单聊消息、群聊消息、系统消息、超级群消息通过第三方推送厂商或融云自建的推送服务通知客户端。这意味着即使用户的应用没有运行，他们也能通过系统通知栏接收到消息提醒。服