SpringMVC+Spring+Mybatis框架整合Mqttt通信协议+ActiveMQ作为中间件进行消息的发布与订阅

单片机部分采用MQTT协议将主题消息发布到队列中，java部分也采用MQTT协议进行处理，整合MQTT协议， 具体这个资源是干什么的,请查看博客： https://blog.csdn.net/qq_34178998/article/details/93158429

package com.zlw.comm.mqtt;

import com.alibaba.fastjson.JSONobject;
import com.zlw.comm.utils.FastJsonUtils;

public class MqttService {
	
	public void startCase（String message）{
		JSONobject jb = FastJsonUtils.toJsonobject（message）;
		System.out.println（“收到32单片机消息：“ + message）;
    }

}

/*public void onMessage（Message message） {
	String responsexml = null;
	if （message instanceof BytesMessage） {
		ActiveMQBytesMessage bytesMessage = （ActiveMQBytesMessage） message;
		byte[] bys = null;
		try {
			bys = new byte[（int） bytesMessage.getBodyLength（）];
			bytesMessage.readBytes（bys）;
			responsexml = new String（bys）;
			*//****************************此处为模拟数据**********************************************//*
			RgModRecordAddWithJon rgAddWithJon = new RgModRecordAddWithJon（）;
			rgAddWithJon.setDevId（（long） 4）;
			rgAddWithJon.setModRecordData（FastJsonUtils.toJsonobject（responsexml））;
			rgAddWithJon.setModRecordUpTime（new Date（））;
			rgAddWithJon.setDevApiKey（StringUtils.getUUId（））;
			recordExtMapper.insertWithJosn（rgAddWithJon）;
			System.out.println（“收到32单片机消息：“ + responsexml）;
		} catch （JMSException e） {
			e.printStackTrace（）;
		}
	} else {
		TextMessage bm = （TextMessage） message;
        try {
            responsexml = bm.getText（）;
            System.out.println（“------------内容是：“ + responsexml）;
        } catch （JMSException e） {
            logger.error（e.getMessage（） e）;
        }
	}

}*/

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       1350  2019-06-18 11:14  zlw\.classpath

     文件         22  2019-06-18 17:00  zlw\.git\COMMIT_EDITMSG

     文件        295  2019-06-18 11:14  zlw\.git\config

     文件         73  2019-06-18 11:14  zlw\.git\description

     文件         90  2019-06-18 13:13  zlw\.git\FETCH_HEAD

     文件         23  2019-06-18 11:14  zlw\.git\HEAD

     文件        478  2019-06-18 11:14  zlw\.git\hooks\applypatch-msg.sample

     文件        896  2019-06-18 11:14  zlw\.git\hooks\commit-msg.sample

     文件       3327  2019-06-18 11:14  zlw\.git\hooks\fsmonitor-watchman.sample

     文件        189  2019-06-18 11:14  zlw\.git\hooks\post-update.sample

     文件        424  2019-06-18 11:14  zlw\.git\hooks\pre-applypatch.sample

     文件       1638  2019-06-18 11:14  zlw\.git\hooks\pre-commit.sample

     文件       1348  2019-06-18 11:14  zlw\.git\hooks\pre-push.sample

     文件       4898  2019-06-18 11:14  zlw\.git\hooks\pre-rebase.sample

     文件        544  2019-06-18 11:14  zlw\.git\hooks\pre-receive.sample

     文件       1492  2019-06-18 11:14  zlw\.git\hooks\prepare-commit-msg.sample

     文件       3610  2019-06-18 11:14  zlw\.git\hooks\update.sample

     文件      25259  2019-06-21 09:36  zlw\.git\index

     文件        240  2019-06-18 11:14  zlw\.git\info\exclude

     文件        942  2019-06-18 17:00  zlw\.git\logs\HEAD

     文件        942  2019-06-18 17:00  zlw\.git\logs\refs\heads\master

     文件        173  2019-06-18 11:14  zlw\.git\logs\refs\remotes\origin\HEAD

     文件        286  2019-06-18 13:53  zlw\.git\logs\refs\remotes\origin\master

     文件         45  2019-06-18 13:54  zlw\.git\objects\07\9d16d13f36fdb68f5a12c742cb4182eac721b5

     文件        106  2019-06-18 17:00  zlw\.git\objects\0c\ec052748c72b5f89cdccd782729f2c7a544925

     文件        648  2019-06-18 17:00  zlw\.git\objects\0d\65dc00434560f6be273d538427a7d2174b5122

     文件        110  2019-06-18 13:11  zlw\.git\objects\1f\0dfffe0594a5cdc254f6f77703adf1a7f824aa

     文件        708  2019-06-18 13:54  zlw\.git\objects\20\9bb03d30154b9a1027dc0fa6d47a326b76a7b6

     文件         46  2019-06-18 14:01  zlw\.git\objects\21\0169d7a8f4cb7bc7392336e297146d1dd3da9b

     文件        390  2019-06-18 17:00  zlw\.git\objects\21\59ebc6de5b7ace6fc01b5b496e9a7a90a9036e

............此处省略589个文件信息