1.SpringCloudStream的使用 ①安装中间件，根据实际需要安装消息中间件（以RabbitMQ为例介绍） ②创建服务生成者 引入依赖 编写配置 编码 执行流程 ③创建服务消费者 引入依赖（同生产者一样的依赖） 配置 编码 2.自定义消息通道 使用自定义通道 自定义通道配置 3.消息分组（ ...
分类：
编程语言 时间：
2020-05-05 01:05:53
阅读次数：
86
首先登陆EAC，然后在EAC中，转到收件人>组>具体步骤如下：1.先创建一个通讯组2.然后创建一条规则3.设置规则条件，详细配置如下图：选中第1步创建的用户组，配置条件，同时可以添加用户组例外，最后添加描述。
分类：
其他好文 时间：
2020-05-04 23:02:03
阅读次数：
77
一、思路 一般在开发过程中：生产者工程：1. application.yml文件配置RabbitMQ相关信息；2. 在生产者工程中编写配置类，用于创建交换机和队列，并进行绑定3. 注入RabbitTemplate对象，通过RabbitTemplate对象发送消息到交换机消费者工程：1. applic ...
分类：
编程语言 时间：
2020-05-04 19:33:25
阅读次数：
79
我们将rabbitmq_management这个插件启动，然后就好了 docker exec -it rabbit rabbitmq-plugins enable rabbitmq_management ...
分类：
Web程序 时间：
2020-05-04 15:40:22
阅读次数：
53
单机系统的时候，客户端和连接都有同一台服务器管理。 image.png 在本地维护一份userId到connetciont的映射 服务器可以根据userId找出对应的连接，然后把消息push出去 image.png 但是集群环境下，连接分布在不同的机器，小明向小张发消息时跨了机器 image.png ...
分类：
其他好文 时间：
2020-05-02 15:18:05
阅读次数：
97
喜欢关注个人公众号：java乐园消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构；是大型分布式系统不可缺少的中间件。目前使用较多的消息队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ、MetaMQ等。springboot提供了对JMS系统的支持；springboot很方便就可以集成这些消息中间件。对
分类：
编程语言 时间：
2020-05-02 09:27:36
阅读次数：
55
一、消息为什么丢失 RabbitMQ默认情况下的交换机和队列以及消息是非持久化的，也就是说在服务器重启或者宕机恢复后，之前创建的交换机和队列都将不复存在，之前未消费的消息也就消失不见了。原因在于每个队列和交换机的durable属性。该属性默认情况是false，它决定了RabbitMQ是否需要在崩溃或 ...
分类：
其他好文 时间：
2020-05-01 16:41:29
阅读次数：
396
rabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业消息系统。它遵循Mozilla Public License开源协议，采用 Erlang 实现的工业级的消息队列(MQ)服务器，Rabbit MQ 是建立在Erlang OTP平台上。 1、安装Erlang 下载地址：https:// ...
1、现象： 今天下午公司客户群里突然报警，说订单没有推送服务商，经排查发现是rabbitmq堵住了，查询elk和监控没有发现业务异常或超时日志。 通过rabbitmq后面发现一个队列有异常，队列不ack，未消费数量一直增长，怀疑服务假死，只能保留现场，重启服务，下面是服务重启前后队列截图 2、分析 ...
分类：
其他好文 时间：
2020-04-30 22:58:35
阅读次数：
185
概述canal client将从canal server获取的binlog数据以json格式发送到各种MQ中(rabbitmq，redis，kafka)。部署第一步：下载解压项目，使用的是与canal-server 1.0.22版本对应的client（canal-client-1.0.22.tar. ...
分类：
其他好文 时间：
2020-04-29 18:12:34
阅读次数：
229
