首页 > 系统相关> 文章详细

windows 下搭建 MQTT 服务

2020-06-30 17:09:24 阅读：630 来源： 互联网

标签：windows eclipse System MQTT println org paho out 搭建

1.首先搭建起MQTT服务

1.1安装mosquitto，mosquitto是开源的MQTT代理服务器，它的Windows安装包地址：https://mosquitto.org/download/

1.2 安装、配置ActiveMQ

ActiveMQ 下载地址：http://activemq.apache.org/components/classic/download/

ActiveMQ操作手册：http://activemq.apache.org/getting-started#StartingActiveMQStartingActiveMQ

把下载的压缩包解压以后，放到自己可以方便找到的目录。在这个目录下，进入解压文件包的bin目录，在这个目录下打开cmd窗口，输入activemq start ，按回车MQTT服务启动成功如下

打开ActiveMQ的查看页面： http://127.0.0.1:8161/admin/，输入用户名：admin 密码：admin，进入查看页面，如下图。

2.用java 实现一个MQTT客户端，并发布消息，测试MQTT服务端

2.1 下载mqtt的jar包

地址如下：https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/

2.2 引用官方示例测试，官方示例代码如下：

package com.mqtttest;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
import org.eclipse.paho.client.mqttv3.MqttTopic;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class Main {

    public static void main(String[] args) {
        String topic        = "MQTT Examples";
        String content      = "Message from MqttPublishSample";
        int qos             = 2;
        String broker       = "tcp://127.0.0.1:1883";
        String clientId     = "JavaSample";
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            System.out.println("Connecting to broker: "+broker);
            sampleClient.connect(connOpts);
            System.out.println("Connected");
            System.out.println("Publishing message: "+content);
            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(qos);
            sampleClient.publish(topic, message);
            System.out.println("Message published");
            sampleClient.disconnect();
            System.out.println("Disconnected");
            System.exit(0);
        } catch(MqttException me) {
            System.out.println("reason "+me.getReasonCode());
            System.out.println("msg "+me.getMessage());
            System.out.println("loc "+me.getLocalizedMessage());
            System.out.println("cause "+me.getCause());
            System.out.println("excep "+me);
            me.printStackTrace();
        }
    }
}

运行完毕上面的程序，进入http://localhost:8161/admin/topics.jsp，点击Topics，就可以看到我们发布的消息了，如下图

至此，windows下的 MQTT服务环境搭建完毕。

标签：windows,eclipse,System,MQTT,println,org,paho,out,搭建
来源： https://www.cnblogs.com/greenteaone/p/13214728.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

windows 下搭建 MQTT 服务