EMQTT测试--安装与测试

冷不防 2022-09-24 06:24 228阅读 0赞

[官网][Link 1]

我下载的是windows版

# 安装 #

参考  
[http://emqtt.com/docs/install.html][http_emqtt.com_docs_install.html]

将下载的压缩包解压，我解压到了D盘

![这里写图片描述][20160727134847474]

> 命令行窗口，cd到程序目录
> 
> 控制台模式启动:
> 
> .\\bin\\emqttd console

报错如下

无法启动此程序，因为计算机中丢失 MSVCR120.dll。尝试重新安装该程序以解决次问题。

![这里写图片描述][20160727135124987]

找一个MSVCR120.dll文件，可以去网上下载，也可以在自己电脑上找

![这里写图片描述][20160727135423529]

HBuilder下有  
mqttfx下也有  
XMind下也有  
IDEA下也有

我拷贝一个mqttfx下的到Windows\\System32下

![这里写图片描述][20160727135719913]

然后重新执行

.\bin\emqttd console

启动成功

![这里写图片描述][20160727140033242]

[http://localhost:18083/][http_localhost_18083]

用户名为admin密码为public

![这里写图片描述][20160727140502075]

登录上去就可以看服务器的运行状态了

![这里写图片描述][20160727142440588]

# 测试 #

## 依赖 ##

<dependency>
            <groupId>org.eclipse.paho</groupId>
            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
            <version>1.0.2</version>
        </dependency>

## Server ##

package com.mymqtt.myemqtt;
    
    import java.util.Scanner;
    
    import org.eclipse.paho.client.mqttv3.MqttClient;
    import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
    import org.eclipse.paho.client.mqttv3.MqttMessage;
    
    public class Server {
    
        public static void main(String[] args) throws Exception {
            String host = "tcp://127.0.0.1:1883";
            String topic = "hello";
            String clientId = "server";// clientId不能重复
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
    
            MqttClient client = new MqttClient(host, clientId);
            client.connect(options);
    
            MqttMessage message = new MqttMessage();
    
            @SuppressWarnings("resource")
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入要发送的内容：");
            while (true) {
                String line = scanner.nextLine();
                message.setPayload(line.getBytes());
                client.publish(topic, message);
            }
    
        }
    }

## Client ##

package com.mymqtt.myemqtt;
    
    import org.eclipse.paho.client.mqttv3.MqttClient;
    import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
    
    public class Client { 
    
        public static void main(String[] args) throws Exception {
    
            String host = "tcp://127.0.0.1:1883";
            String topic = "hello";
            String clientId = "12345";// clientId不能重复
            // 1.设置mqtt连接属性
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
            // 2.实例化mqtt客户端
            MqttClient client = new MqttClient(host, clientId);
            // 3.连接
            client.connect(options);
    
            client.setCallback(new PushCallback());
            while (true) {
                client.subscribe(topic, 2);
            }
            // client.disconnect();
        }
    }

## PushCallback ##

package com.mymqtt.myemqtt;
    
    import java.util.Date;
    
    import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
    import org.eclipse.paho.client.mqttv3.MqttCallback;
    import org.eclipse.paho.client.mqttv3.MqttMessage;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    public class PushCallback implements MqttCallback { 
        private final Logger logger = LoggerFactory.getLogger(this.getClass());
    
        public void connectionLost(Throwable cause) {
            // 连接丢失后，一般在这里面进行重连
            System.out.println("连接断开，可以做重连");
            logger.info("掉线时间:{}", new Date());
        }
    
        public void deliveryComplete(IMqttDeliveryToken token) {
            System.out.println("deliveryComplete---------" + token.isComplete());
        }
    
        public void messageArrived(String topic, MqttMessage message) throws Exception {
            // subscribe后得到的消息会执行到这里面
            // System.out.println(message);
            System.out.println("接收消息主题 : " + topic);
            System.out.println("接收消息Qos : " + message.getQos());
            System.out.println("接收消息内容 : " + new String(message.getPayload()));
        }
    
    }

## 结果 ##

![这里写图片描述][20160727144718337]

## 控制台显示 ##

### 两个连接 ###

![这里写图片描述][20160727144813014]

# 参考文献 #

> [http://emqtt.com/][Link 1]
> 
> [百度开放云物接入IoT–Java客户端][IoT_Java]

[Link 1]: http://emqtt.com/
[http_emqtt.com_docs_install.html]: http://emqtt.com/docs/install.html
[20160727134847474]: /images/20220719/e88b584a77fb49d5b575e2513003d305.png
[20160727135124987]: /images/20220719/36fbd490479d4a448fcccb8e49e2477a.png
[20160727135423529]: /images/20220719/77eaa69c28e940e891ed9497303124d7.png
[20160727135719913]: /images/20220719/1d0cbeaf052947b5aee2b7575d32ed77.png
[20160727140033242]: /images/20220719/fc648e8ce742410189c0e45b226e59b1.png
[http_localhost_18083]: http://localhost:18083/
[20160727140502075]: /images/20220719/6c602523947447c08bd933e9ac368b07.png
[20160727142440588]: /images/20220719/9e9982eeb6724caa818f705d77c3650f.png
[20160727144718337]: /images/20220719/0c372a726002453789d7c63df5e43ba4.png
[20160727144813014]: /images/20220719/8073e51d0ae8447db55973e03d41423c.png
[IoT_Java]: http://blog.csdn.net/frankcheng5143/article/details/51729255