这篇文章主要讲解了“前端与RabbitMQ实时消息推送怎么实现”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“前端与RabbitMQ实时消息推送怎么实现”吧！web 端实时消息推送，常用的实现方式比较多，但万变不离其宗，底层基本上还是依赖于 websocket，MQTT 协议也不例外。RabbitMQ的基础搭建就不详细说了，自行百度一步一步搞问题不大，这里主要说一下两个比较重要的配置。默认情况下RabbitMQ是不开启MQTT 协议的，所以需要我们手动的开启相关的插件，而RabbitMQ的MQTT 协议分为两种。第一种 rabbitmq_mqtt 提供与后端服务交互使用，对应端口1883。第二种 rabbitmq_web_mqtt 提供与前端交互使用，对应端口15675。在 RabbitMQ 管理后台看到如下的显示，就表示MQTT 协议开启成功，到这中间件环境就搭建完毕了。使用MQTT 协议默认的交换机 Exchange 为 amp.topic，而我们订阅的主题会在 Queues 注册一个客户端队列，路由 Routing key 就是我们设置的主题。web 端实时消息推送一般都是单向的推送，前端接收服务端推送的消息显示即可，所以就只实现消息发送即可。引入 spring-integration-mqtt、org.eclipse.paho.client.mqttv3两个工具包实现消息的发送比较简单，主要是应用到 @ServiceActivator 注解，需要注意messageHandler.setAsync属性，如果设置成 false，关闭异步模式发送消息时可能会阻塞。MQTT 对外提供发送消息的 API 时，需要使用 @MessagingGateway注解，去提供一个消息网关代理，参数 defaultRequestChannel 指定发送消息绑定的channel。可以实现三种API接口，payload 为发送的消息，topic 发送消息的主题，qos 消息质量。前端使用与服务端对应的工具 paho-mqtt mqttws31.js实现，实现方式与传统的 websocket 方式差不多，核心方法 client = new Paho.MQTT.Client 和 各种监听事件，代码比较简洁。注意：要保证前后端 clientId的全局唯一性，我这里就简单用随机数解决了前后端的代码并不多，接下来我们测试一下，弄了个页面看看效果。首先用 postman 模拟后端发送消息感谢各位的阅读，以上就是“前端与RabbitMQ实时消息推送怎么实现”的内容免费云主机域名了，经过本文的学习后，相信大家对前端与RabbitMQ实时消息推送怎么实现这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是百云主机，小编将为大家推送更多相关知识点的文章，欢迎关注！
本篇内容主要讲解“Java的内部类和异常类如何区分”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Java的内部类和异常类如何区分”吧!Java支持在一个类中声明另一个类，这样的类称作内部类，而包含内部类的类成为内部…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
