前言

最近自己搭建了个项目，项目本身很简单，但是里面有使用WebSocket进行消息提醒的功能，大体情况是这样的。

发布消息者在系统中发送消息，实时的把消息推送给对应的一个部门下的所有人。

这里面如果是单机应用的情况时，我们可以通过部门的id和用户的id组成一个唯一的key，与应用服务器建立WebSocket长连接，然后就可以接收到发布消息者发送的消息了。

但是真正把项目应用于生产环境中时，我们是不可能就部署一个单机应用的，而是要部署一个集群。

安装的环境与版本

CentOs7，

RabbitMQ 3.6.5，

erlang 18.3，

socat

获取安装包

文章目录

• 一、Kettle为什么可以读取流数据？

阅读目录

1. 环境

O 操作系统：openEuler 22.03 (LTS-SP2)

2. 下载

O Erlang：

消息追踪

在使用任何消息中间件的过程中，难免会出现某条消息异常丢失的情况。对于 RabbitMQ 而言，可能是因为生产者或消费者与RabbitMQ 断开了连接，而它们与 RabbitMQ 又采用了不同的确认机制；也有可能是因为交换器与队列之间不同的转发策略；甚至是交换器并没有与任何队列进行绑定，生产者又不感知或者没有采取相应的措施；另外 RabbitMQ 本身的集群策略也可能导致消息的丢失。这个时候就需要有一个较好的机制跟踪记录消息的投递过程，以此协助开发和运维人员进行问题的定位。

## 为客户端和服务器生成自签名证书

为了启用 TLS/SSL，我们需要证书/密钥对。 这可以借助 OpenSSL 为客户端和服务器生成自签名证书。

1. **生成自签名CA证书**

关注

本文介绍了分布式任务调度系统Celery，包括安装，开发使用，并且配合supervisor，flower等工具进行系统化部署和使用。

（一）安装和代码开发使用示例

一，简介

思维导航：

• 基础
• 为什么使用 MQ？