下载ActiveMQ:
解压缩文件,例如:E:/apache-activemq-5.16.0 。
ActiveMQ依赖JAVA环境,需要JAVA_HOME等环境变量的正确设置。
启动系统的命令为:
cd E:/apache-activemq-5.16.0
bin/activemq start
启动成功后,出现如下黑窗口
下载MQTTBOX,这是MQTT的客户端。https://s3-us-west-2.amazonaws.com/workswithweb/mqttbox/latest/windows/MQTTBox-win.exe
安装MQTTBox-win.exe这个东西。
打开这个安装后的程序MQTTBox.exe
点击Create MQTT Client,创建一个客户端的配置信息。
因为测试的ActiveMQ安装在本机,所以Host填写127.0.0.1这个本机回环地址。1883是MQTT著名端口号。
点击Save可以保存,点击Delete是删除这个配置。
我们会发现,立刻连接成功了,是绿色的Connected标志,如下图所示。
点击Add subscriber,添加一个订阅。
点击Subcribe确认添加。得到如下页面:
我们可以打开另一个MQTTBox.exe
输入要发布的主题:Topic to publish = abc, 负载Payload = asdasd,点击Publish发布一下。看到另一个客户端收到消息,内容如下:
测试基本成功。
ActiveMQ有个后台管理页面(WebConsole):http://127.0.0.1:8161
在connecttions Tab页里,是当前的两个客户端。
如果要关闭ActiveMQ,需要再打开一个新的cmd窗口(不是启动ActiveMQ用到的那个cmd窗口)。输入:
cd E:/apache-activemq-5.16.0/bin
activemq stop
此时客户端的连接状态变红:Connection Error
这说明MQTT基于TCP的事实。当服务端关闭后,客户端也无法连接到服务端了。