MQTT mosquitto 服务端客户端Demo 可直接使用的工具类

【实例简介】
网上可以找到的mosquitto真的不多，俺这种不是什么技术大牛的人搞起来真的好费工夫。 在此本着共享精神跟大家分享。（其中的服务端的类基本上使用了网络上一位朋友的共享）由于是整整三天的调查成果，因此例外拿个10分，请大家体谅。但我相信你不会失望的。 CMain展示了Server和Client端的Util用法，以java工程运行CMain可以进行测试，可以选择测试publish（发布）或subscribe（订阅）， 可使用Mosquitto命令行配合进行测试。 使用前配置properties文件中的brorkerServer的IP和端口。 当然，首先要先安装Mosquitto，并启动mosquitto服务。 服务器端大家直接在这里下载： http://www.eclipse.org/downloads/download.php?file=/mosquitto/binary/win32/mosquitto-1.4.2-install-win32.exe 或者这个地址：http://mosquitto.org/files/binary/win32/mosquitto-1.0.3-install-win32.exe 然后用命令行就可以发布和订阅消息了： #首先启动服务 mosquitto -c mosquitto.conf #例：在测试服务端publish方法时，使用下面的命令，订阅topic为KCBZ的消息 （IP地址与config.properties中ServerIP保持一致）# mosquitto_sub -h 192.168.4.71 -p 1883 -t KCBZ #例：在测试客户端subscribe方法时，使用下面的命令，发布一个topic为KCBZ的消息） mosquitto_pub -h 192.168.4.71 -p 1883 -t KCBZ -m 您的库存不足
【实例截图】
【核心代码】
4744302543458130124.zip
└── MQTTServerDemo
├── bin
│   ├── CMain$1.class
│   ├── CMain.class
│   ├── KtMqttMsgCallback.class
│   ├── log4j.properties
│   ├── LogUtil.class
│   ├── MqttAsyncCallBack$Disconnector$1.class
│   ├── MqttAsyncCallBack$Disconnector.class
│   ├── MqttAsyncCallBack$MqttConnector$1.class
│   ├── MqttAsyncCallBack$MqttConnector.class
│   ├── MqttAsyncCallBack$Publisher$1.class
│   ├── MqttAsyncCallBack$Publisher.class
│   ├── MqttAsyncCallBack$Subscriber$1.class
│   ├── MqttAsyncCallBack$Subscriber.class
│   ├── MqttAsyncCallBack.class
│   ├── MqttClientUtil.class
│   ├── MqttServerUtil.class
│   ├── PropUtil.class
│   └── vendingConfig.properties
├── lib
│   ├── commons-logging-1.1.1.jar
│   ├── log4j-1.2.17.jar
│   └── org.eclipse.paho.client.mqttv3-1.0.1-20141007.040217-92.jar
└── src
├── CMain.java
├── KtMqttMsgCallback.java
├── log4j.properties
├── LogUtil.java
├── MqttAsyncCallBack.java
├── MqttClientUtil.java
├── MqttServerUtil.java
├── PropUtil.java
└── vendingConfig.properties

4 directories, 30 files