1.RabbitMQ 和 MQTT 实践 web消息实时推送（这个小红点）
2.org.eclipse.paho.client.mqttv3.MqttSecurityException: 无权连接
3.UE插件DTRabbitMQ 虚幻引擎蓝图连接RabbitMQ服务器使用插件说明

RabbitMQ 和 MQTT 实践 web消息实时推送（这个小红点）

       前几天粉丝群里有个小伙伴问过：web 页面的源码未读消息（小红点）怎么实现比较简单，刚好本周手头有类似的源码开发任务，索性就整理出来供小伙伴们参考，源码没准哪天就能用得上呢。源码

       之前在 《springboot + rabbitmq 做智能家居》 中说过可以用 rabbitmq 的源码 MQTT 协议做智能家居的指令推送，里边还提到过能用 MQTT 协议做 web 的源码文华副图多空指标源码消息推送，而未读消息（小红点）功能刚好应用到实时消息推送了。源码

       MQTT 协议就不再赘述了，源码没接触过的源码同学翻翻前边的文章温习一下吧，今天还是源码主要以实践为主！

       web 端实时消息推送，源码常用的源码实现方式比较多，但万变不离其宗，源码底层基本上还是源码juc源码剖析依赖于 websocket，MQTT 协议也不例外。源码

       RabbitMQ 搭建，基础搭建就不详细说了，自行百度一步一步搞问题不大，这里主要说一下两个比较重要的配置。首先，开启 mqtt 协议，因为默认情况下RabbitMQ是不开启MQTT 协议的，所以需要我们手动的开启相关的插件，而RabbitMQ的MQTT 协议分为两种。第一种rabbitmq_mqtt 提供与后端服务交互使用，对应端口。第二种rabbitmq_web_mqtt 提供与前端交互使用，dex还原源码对应端口。在RabbitMQ 管理后台看到如下的显示，就表示MQTT 协议开启成功，到这中间件环境就搭建完毕了。使用MQTT 协议默认的交换机 Exchange 为 amp.topic，而我们订阅的主题会在 Queues 注册一个客户端队列，路由 Routing key 就是我们设置的主题。

       服务端消息发送，web 端实时消息推送一般都是单向的推送，前端接收服务端推送的消息显示即可，所以就只实现消息发送即可。引入spring-integration-mqtt、org.eclipse.paho.client.mqttv3 两个工具包实现。NFT空投源码消息的发送比较简单，主要是应用到@ServiceActivator 注解，需要注意messageHandler.setAsync属性，如果设置成 false，关闭异步模式发送消息时可能会阻塞。MQTT 对外提供发送消息的 API 时，需要使用 @MessagingGateway 注解，去提供一个消息网关代理，参数 defaultRequestChannel 指定发送消息绑定的channel。可以实现三种API接口，payload 为发送的消息，topic 发送消息的主题，qos 消息质量。vs报价源码

       前端消息订阅，前端使用与服务端对应的工具paho-mqtt mqttws.js实现，实现方式与传统的 websocket 方式差不多，核心方法 client = new Paho.MQTT.Client 和 各种监听事件，代码比较简洁。注意：要保证前后端 clientId的全局唯一性，我这里就简单用随机数解决了。

       测试，前后端的代码并不多，接下来我们测试一下，弄了个页面看看效果。首先用postman 模拟后端发送消息。再看一下前端订阅消息的效果，看到消息被实时推送到了前端，这里只做了未读消息数量统计，一般还会做未读消息详情列表。

       总结，未读消息是一个十分常见的功能，不管是web端还是移动端系统都是必备的模块，MQTT 协议只是其中的一种实现方式，还是有必要掌握一种方法。具体用什么工具实现还是要看具体的业务场景和学习成本，像我用RabbitMQ 做还考虑到一些运维成本在里边。本文完整代码地址：/chengxy-nds/Springboot-Notebook/tree/master/springboot-mqtt-messagepush

org.eclipse.paho.client.mqttv3.MqttSecurityException: 无权连接

       之前在本地安装的RabbitMQ没有出现问题，直到完成功能后准备进行测试时遇到了问题。现在需要在IP地址为..3.的局域网服务器上部署一个RabbitMQ中间件，并通过我本机上的程序与其进行通讯。

       通过localhost:和.0.0.1:访问本机上的RabbitMQ没有问题，但是除了这两个IP地址外，其他所有的IP地址都会报错，包括本机的IP地址..3.。

       使用MQTT.FX订阅了communication/2/#，在..3.的RabbitMQ发送一条消息进行测试，能够成功接收消息。

       以下是相关代码：

       MqttGateway.java

       MqttInboundConfig.java

       MqttOutboundConfig.java

       application.yml

UE插件DTRabbitMQ 虚幻引擎蓝图连接RabbitMQ服务器使用插件说明

       本文介绍一款名为DTRabbitMQ的虚幻引擎UE插件，该插件能够通过蓝图连接RabbitMQ服务器，实现消息的推送与监听。插件功能与使用方法如下：

       首先，创建一个RabbitMQ客户端对象（Create RabbitMQ Client），并将返回的对象提升为变量，用于后续操作。

       链接服务器（Connect），需要提供服务器IP地址（Host），服务器端口（Port），账号（User Name），密码（Password），以及虚拟主机（Virtual Host），默认值为“/”。心跳包间隔（Heartbeat）可设置为默认值或稍微改小以监控网络状态。

       发送消息至服务器队列（Publish），需要指定连接通道ID（默认1）、推送的交换器名称（Exchange）以及路由密匙（Routing）。消息内容（Body）可为字符串或Json格式。

       绑定消息回调（Bind Message Delegate），设置连接通道ID、队列名称（Queue Name）与是否自动确定消息（Auto Acknowledges）。回调函数（On Rabbit MQ Message）由开发者自定义。

       消息确认（Acknowledges），指定连接通道ID与需要确认的消息标识（Delivery Tag）。确认方式可通过参数Multiple控制，决定是否确认所有传递标记之前的消息。

       断开服务器链接（Disconnect），清空所有消息监听，完成与RabbitMQ服务器的断开连接。

       链接失败回调（Bind Connection Close Delegate）自动处理与服务器链接失败或异常断开的情况。

       使用案例部分，详细步骤与代码示例，以及插件下载地址，将在后续更新中提供。敬请期待。