Activemq MQTT 简单消息推送示例

简介

简单使用 MQTT 连接 Activemq 进行消息推送的示例代码

编写详情

环境准备

使用docker启动Activemq，查看MQTT协议监听端口是否正确，如下命令，显示1883：

docker run -dit --name activemq -p 11616:61616 -p 8161:8161 -p 1883:1883 rmohr/activemq
docker exec -ti activemq cat /opt/activemq/conf/activemq.xml

订阅者

类似手机客户端，接收消息推送，简单打印收到的消息，代码如下：

import org.fusesource.hawtbuf.Buffer;
import org.fusesource.hawtbuf.UTF8Buffer;
import org.fusesource.mqtt.client.*;public class Listener {public static void main(String[] args) throws Exception {MQTT mqtt = new MQTT();mqtt.setHost("localhost", 1883);mqtt.setUserName("admin");mqtt.setPassword("admin");final CallbackConnection connection = mqtt.callbackConnection();connection.listener(new org.fusesource.mqtt.client.Listener() {@Overridepublic void onConnected() {}@Overridepublic void onDisconnected() {}@Overridepublic void onPublish(UTF8Buffer utf8Buffer, Buffer buffer, Runnable runnable) {String message = buffer.utf8().toString();System.out.println("Receive message : " + message);}@Overridepublic void onFailure(Throwable throwable) {}});connection.connect(new Callback<Void>() {@Overridepublic void onSuccess(Void aVoid) {Topic[] topics = {new Topic("mqttTest", QoS.AT_LEAST_ONCE)};connection.subscribe(topics, new Callback<byte[]>() {@Overridepublic void onSuccess(byte[] bytes) {System.out.println("subscribe success");}@Overridepublic void onFailure(Throwable throwable) {System.out.println("subscribe failed");}});}@Overridepublic void onFailure(Throwable throwable) {}});synchronized (Listener.class) {while (true) {Listener.class.wait();}}}
}

发布者

进行消息的发布，代码大致如下：

import org.fusesource.hawtbuf.AsciiBuffer;
import org.fusesource.hawtbuf.UTF8Buffer;
import org.fusesource.mqtt.client.FutureConnection;
import org.fusesource.mqtt.client.MQTT;
import org.fusesource.mqtt.client.QoS;public class Publisher {public static void main(String[] args) throws Exception {MQTT mqtt = new MQTT();mqtt.setHost("localhost", 1883);mqtt.setUserName("admin");mqtt.setPassword("admin");FutureConnection connection = mqtt.futureConnection();connection.connect().await();System.out.println("connect");int messageAmount = 10;UTF8Buffer topic = new UTF8Buffer("mqttTest");while (messageAmount > 0) {connection.publish(topic, new AsciiBuffer("test message" + messageAmount), QoS.AT_LEAST_ONCE, false);System.out.println("send message " + messageAmount);messageAmount -= 1;}connection.disconnect().await();System.out.println("disconnect");}
}

运行

先启动订阅者，再启动发布者，可以看到消息发送和接收

参考链接

ActiveMq之MQTT（即时聊天&物联网技术）
MQTT
activemq example:
- Listener.java
- Publisher.java
- pom.xml

Activemq MQTT 简单消息推送示例相关推荐

Android MQTT实现消息推送
飞哥语录:编程说白了就是发送数据,接收数据,处理数据. 1.概述 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,有 ...
基于MQTT的消息推送
这段时间学习了推送技术,对xmpp和mqtt 协议做了下比较. xmpp基于xml信息传递,所以传输信息量比较大,在保持长链接情况下功耗会比较大. 可能还是比较适合用来做聊天之类的通讯应用,而对于智能 ...
netty websocket 简单消息推送demo
2019独角兽企业重金招聘Python工程师标准>>> 今天心情很不好!!! 原因保密. 这篇是基于"netty与websocket通信demo". 错误想法:大 ...
java socket wex5_WeX5集成ActiveMQ+WebSocket实现消息推送
1 首先下载并安装ActiveMQ http://www.apache.org/dyn/closer.cgi?path=/activemq/apache-activemq/5.9.0/apache- ...
浏览器WebSocket连接apollo的MQTT实现消息推送（WEB系统微信扫码登录）
序一直就想搭建消息队列的,因为目前业务发展还没有到这块,一直没有搭建.刚好今天接到的一个需求是web系统实现微信扫码登录,另外我们的微信对接是统一的中台接口对接,所以我们没办法做到回调我们的web业 ...
Android平台上使用MQTT协议实现消息推送功能
MQTT实现消息推送,效果如下服务端下载地址:http://activemq.apache.org/download-archives.html jar包地址百度网盘:https://pan.ba ...
持续集成之消息推送：钉钉与企业微信的群聊机器人通用示例
使用钉钉和企业微信的群聊机器人可以进行消息推送,这篇文章使用一个简单的脚本来说明其使用方式. 推送消息的方法钉钉或者企业微信的群机器人都可提供消息推送的功能,相关的机器人的添加和消息推送的方法可以参 ...
SpringBoot如何集成MQTT消息推送
1.需求分析近期笔者项目需要用到mqtt实现消息推送,笔者选择emq作为mqtt服务器载体,上篇笔者讲解了如何在linux中安装mqtt服务:https://blog.csdn.net/zhangx ...
Web 实时消息推送详解
title: Web 实时消息推送详解 category: 系统设计 head: meta name: keywords content: 消息推送,短轮询,长轮询,SSE,Websocket,MQT ...

Activemq MQTT 简单消息推送示例

Activemq MQTT 简单消息推送示例

简介

编写详情

环境准备

订阅者

发布者

运行

参考链接

Activemq MQTT 简单消息推送示例相关推荐

最新文章

热门文章