基於java實現的一個mqtt客戶端鏈接工具包:shap-mqtthtml
這是我第一款發佈的開源工具java
訂閱,須要繼承IShapListener接口git
public class NcSubscribe implements IShapListener { @Override public void messageArrived(String topic, MqttMessage message) throws Exception { System.out.println("topic:"+topic); System.out.println("id:"+message.getId()); System.out.println("qos:"+message.getQos()); System.out.println("context:"+message.getPayload()); } }
發佈,使用類ShapMqtt.publish(...)github
class Test { public static void main(String[] args){ ShapMqtt shapMqtt = new ShapMqtt("tcp://127.0.0.1:1883"); shapMqtt.subscribe("hello/+",new NcSubscribe()); shapMqtt.publish("hello/one",1,"hello world!".getBytes(),false); } }
Maven pom.xml中能夠之間引用maven
groupId: com.github.owen-jia artifactId: shap-mqtt version: 0.0.1
差很少花了2小時,看了網上一篇博客建立nexus賬號配置maven pom再deploy成功。tcp
這兩篇文章很靠譜,按流程走一次性就成功了;ide
官方辦事效率真是讓人欽佩不已,1小時內搞定審覈。工具
Maven中央倉庫的更新速度也是使人佩服,才上傳完立馬就能在項目中引入使用。.net
做者:Owen Jiacode
推薦關注他的博客:Owen Blog
公衆號: 冬天就要吃胖點