我的物联项目环境搭建（4）服务端代码指令下发（测试版）

本是古典何须时尚 2022-05-09 13:00 167阅读 0赞

**服务端代码指令下发（测试版）**

public class MqttDevice{
    	public static final String MQTT_HOST = "tcp://XXx.168.1.XXX:1883";
    	private static final String MQTT_CLIENT = "XXX_";
    	public static MqttDevice mqttServiceClient = null;
    	private MqttClient client = null;
    	private MqttConnectOptions options = null;
    	
    	public static MqttDevice getInstance() {
    		if (mqttServiceClient == null) {
    			mqttServiceClient = new MqttDevice();
    		}
    		return mqttServiceClient;
    	}
    
    	private MqttDevice() {
    		init();
    	}
    	private void init() {
    		try {
    			client = new MqttClient(MQTT_HOST, MQTT_CLIENT, new MemoryPersistence());
    			options = new MqttConnectOptions();
    	        options.setCleanSession(true);
    	        options.setConnectionTimeout(50);
    			options.setKeepAliveInterval(30);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	void connect() {
    		try {
    			client.connect(options);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	public void disconnect() {
    		try {
    			client.disconnect();
    		} catch (MqttSecurityException e) {
    			e.printStackTrace();
    		} catch (MqttException e) {
    			e.printStackTrace();
    		}
    	}
    	/** 
    	 * 发布消息
    	 * @param topic 主题
    	 * @param msg 消息
    	 */
    	public void publish(String topic, String msg) {
    		try {
    			MqttTopic mqttTopic = client.getTopic(topic);
    			MqttDeliveryToken messageToken = mqttTopic.publish(msg.getBytes("UTF-8"), 2, true);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	public void connectionLost(Throwable cause) {
    
    	}
    	public void messageArrived(MqttTopic topic, MqttMessage message)
    			throws Exception {
    	}
    	public void deliveryComplete(MqttDeliveryToken token)  {
    	
    	}
    	public static void main(String[] args)throws Exception {
    		MqttDevice.getInstance().connect();
    
    		new Thread() {
    			public void run() {
    				
    				int count = 0;
    				while(true) {
    					try {
    						Thread.sleep(1000*3);
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					}
    				  Date jcdate=new Date();
    			        SimpleDateFormat jcdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    			        String jctime=jcdf.format(jcdate);
    			        
    			        if(count%2==0){
    					MqttDevice.getInstance().publish("inTopic", "0");
    			        }else{
    					MqttDevice.getInstance().publish("inTopic", "1");
    			        }
    			
    					
    					System.out.println("已经发送消息。。。"+count);
    				count ++;
    				}
    			};
    		}.start();
    	}
    }