搭建windows平台下的MQTT平台

1.下载Apollo服务器，下载地址http://activemq.apache.org/apollo/download.html，选择window版本下载。下载到桌面而且解压。经过命令行进入这个文件夹中，运行在apache-apollo-1.7.1\bin\中的apollo.cmd文件，在后面加上参数create mybroker便可建立一个服务器实例。若是建立失败，运行不正常，须要检查电脑是否装有java环境。html

2.运行服务器，在上一步新建的mybroker文件夹中生成有apollo-broker.cmd文件，在命令行中运行它，后面加上命令run，便可运行服务器。java

3.打开浏览器python

查看命令行中生成的结果apache

能够看到后台的位置为http://127.0.0.1:61680/浏览器

在浏览器中输入ip地址，进入服务器的面板。服务器

打开链接选项，能够看到没有一个设备链接到服务器。oop

为了测试效果，编写一个简单的程序，与服务器之间收发数据测试

# -*- coding: utf-8 -*-
"""
Spyder Editor

This is a temporary script file.
"""
# coding=utf-8
import paho.mqtt.client as mqtt
import time

HOST = "127.0.0.1"
PORT = 61613

def client_loop():
    client_id = time.strftime('%Y%m%d%H%M%S',time.localtime(time.time()))
    client = mqtt.Client(client_id)   
    client.username_pw_set("admin", "password")  
    client.on_connect = on_connect
    client.on_message = on_message
    client.connect(HOST, PORT, 60)
    client.loop_forever()

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe("test")

def on_message(client, userdata, msg):
    print(msg.topic+" "+msg.payload.decode("utf-8"))

if __name__ == '__main__':
    client_loop()

这个时候，能够看到在链接的界面出现了其余设备命令行

这样一次简单的通讯就完成了。code