该聊天项目是一个标准的多模块 spring boot 项目，只需要引入四个基本的依赖包。

几乎所有的信息管理系统都会涉及到事务，事务的目的是为了保证数据的一致性，这里说的一致性是数据库状态的一致性。

RabbitMQ是使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP, SMTP, STOMP，也正因如此，它非常重量级，更适合于企业级的开发。同时实现了Broker构架，这意味着消息在发送给客户端时先在中心队列排队。对路由，...

启动Kafka：kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties创建一个叫test的话题，有两个分区，每个分区3个副本：kafka-topics.sh --zookeeper localhost:2181 --create --top......

将以下存储在kafka的topic中的JSON格式字符串，对接存储到Hive的表中

备注：后续操作均需进入 /usr/local/Cellar/kafka/2.0.0/bin 目录下。

2.1、下载安装包 https://github.com/zendesk/maxwell/releases/download/v1.20.0/maxwell-1.20.0.tar.gz 2.2、解压到指定位置

最近在从事实时方面的工作，主要涉及到数据处理、加工及可视化，在采坑的过程中总结出一套比较简单的实时计算方案，供大家参考。主要涉及到几个组件，kafka，flink，redis，druid和es。相信大家对以上几个组件都比较熟悉了，这里就不...

因为业务逻辑从同步代码中移除，所以也要有相应队列处理程序处理消息、执行业务逻辑。随着业务逻辑复杂，会引入更多外部系统和服务，就会越来越多使用MQ，与外部系统解耦合以及提升系统性能。...

Acceptor和Processor之间缓存SocketChannel newConnections队列，保证线程安全顺序。