我的物联项目环境搭建（3）服务端代码（测试版）

爱被打了一巴掌 2022-05-09 13:00 126阅读 0赞

**设备服务端代码**  
接收设备数据：

public class BmxMqttServer implements MqttCallback{  
    	public static final String HOST = "tcp://XXX.168.1.XXX:1883";
        private static final String clientid = "xSvr3";  
        private MqttClient client;  
        private MqttConnectOptions options;  
        private void start() {  
            try {  
            	client = new MqttClient(HOST, clientid, new MemoryPersistence());  
                options = new MqttConnectOptions();  
                options.setCleanSession(true);      
                options.setConnectionTimeout(10);  
                 options.setKeepAliveInterval(20);   
                client.setCallback(this);   
                client.connect(options);  
                client.subscribe("outTopic", 2);
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }  
       
        public static void main(String[] args) throws MqttException {     
        	BmxMqttServer client = new BmxMqttServer();  
            client.start();  
        }
    
    	public void connectionLost(Throwable arg0) {
    	}
    
    	public void deliveryComplete(IMqttDeliveryToken arg0) {
    	}
    	public void messageArrived(String topic, MqttMessage message) throws Exception {
            System.out.println("接收消息主题 : " + topic);  
            System.out.println("接收消息Qos : " + message.getQos());  
            System.out.println("接收消息内容 : " + new String(message.getPayload(),"UTF-8")); 
    	}  
    }