3 阿里云服务器测试服务端

我测试的时候使用的是Ppython，首先在阿里云中需要安装EMQ工具

pip install paho-mqtt

　　然后新建一个python文件

vim serve.py

　　测试代码如下

#!/usr/bin/env python
#coding=utf-8
import paho.mqtt.client as mqtt
 
HOST = "47.104.61.160"//服务器ID
PORT = 1883 //服务器端口号
 
 
def on_message_callback(client, userdata, message):
 
    print(message.topic+" " + ":" + str(message.payload))
 
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe("chanel_01")
 
 
def main():
    client = mqtt.Client('test')
    client.connect(HOST, PORT, 60)
    client.username_pw_set('admin', 'password')
    client.on_connect = on_connect
    client.publish("chanel_01", "666666666", 1)
    # client.subscribe('gg')
    client.on_message = on_message_callback
    client.loop_forever()
 
 
if __name__ == '__main__':
    main()