springboot整合RabbitMQ Mqtt

第一，pom配置，我们需要引入相关jar：

第二，配置MQTT服务器基本信息，在springBoot配置文件applicationproperties中配置，添加如下：

第三，配置MQTT消息推送配置类，

第四，配置MqttGateway消息推送接口类，在sendToMqtt(String data,@Header(MqttHeadersTOPIC)String topic)接口中，data为发送的消息内容，topic为主题。指定topic，则我们的接口可以根据需要，向不同的主题发送消息，方便灵活应用。如果不指定，则使用默认配置的主题。

第五，接口类测试下功能，用Postman调用sendMqttdo接口，往hello主题发送消息，用MQTTLens订阅hello主题，从下面截图，可以看出可以正常往MQTT服务发送消息了，而且可以订阅到。

是的，mb_client可以同时读取和写入。mb_client是一个轻量级的客户端库，可用于与MQTT服务器进行交互。它支持客户端端口的双向通信，并提供了简单的API来连接到基于MQTT的服务器。可以使用mb_client来实现双向读取和写入，以便可以从服务器读取数据并将数据写入服务器。此外，mb_client还可以支持发布/订阅模式，以便可以从服务器收到消息，也可以向服务器发布消息。mb_client还支持断开连接和断开重连，以确保可以在任何时候与服务器保持连接。它还支持认证，以便可以与服务器进行安全的通信。

MQTT 协议 因为其轻量、灵活等特点成为了当今世界上最受欢迎的物联网协议，它已经广泛应用于车联网、智能家居、物流、即时聊天应用和移动消息推送等领域，连接了数以亿计的设备，并且每时每刻都有无数设备开始使用和接入 MQTT 协议。MQTT 协议为这些设备提供了稳定、可靠的通信基础，这些设备庞大的接入数量也向 MQTT 协议规范提出了挑战， MQTT 50 的诞生便是为了更好地满足这一需求。

MQTT（消息队列遥测传输）最初由 IBM 于上世纪 90 年代晚期发明。它最初的用途是将石油管道上的传感器与卫星相链接，所以 MQTT 从诞生之初就是专为受限设备和低带宽、高延迟或不可靠的网络而设计，它使用了发布订阅模型，在空间和时间上解耦了消息的发送者与接收者，并且基于 TCP/IP 提供稳定可靠的网络连接，拥有非常轻量的报头以减少传输开销，支持可靠消息传输，可以说天生就满足了物联网场景的各种需求。在 MQTT 311 发布并成为 OASIS 标准的四年后，MQTT 50 正式发布，这是一次重大的改进和升级，它的目的不仅仅是满足现阶段的行业需求，更是为行业未来的发展变化做了充足的准备。2019 年 3 月，MQTT 50 成为了新的 OASIS 标准。

面对迅速增长的设备数量和层出不穷的需求，OASIS MQTT 技术委员会需要从繁杂的需求中提取出通用部分，将其纳入标准规范，并且尽可能不增加开销或降低易用性，在不增加不必要的复杂性的前提下提高性能和易用性。

最终，OASIS MQTT 技术委员会为 MQTT 50 添加了大量的全新功能与特性，50 成为 MQTT 有史以来变化最大的一个版本。在这里，我们将列举一些比较重要的特性：

完整的新属性列表包含在协议标准的附录C，您可以访问以下网址了解详情： >1 从Service继承一个类。
2 创建startService()方法。
3 创建endService()方法 重载onCreate方法和onDestroy方法，并在这两个方法里面来调用startService以及endService。
4 在startService中，通过getSystemService方法获取ContextLOCATION_SERVICE。
5 基于LocationListener实现一个新类。默认将重载四个方法onLocationChanged、onProviderDisabled、onProviderEnabled、onStatusChanged。对于onLocationChanged方法是我们更新最新的GPS数据的方法。一般我们的 *** 作都只需要在这里进行处理。
6 调用LocationManager的requestLocationUpdates方法，来定期触发获取GPS数据即可。在onLocationChanged函数里面可以实现我们对得到的经纬度的最终 *** 作。
7 最后在我们的Activity里面通过按钮来启动Service，停止Service。
示意代码如下：
package comoffbyegpsservice;
import androidappService;
import androidcontentContext;
import androidcontentIntent;
import androidlocationLocationListener;
import androidlocationLocationManager;
import androidosBinder;
import androidosIBinder;
import androidutilLog;
public class GPSService extends Service {
// 2000ms
private static final long minTime = 2000;
// 最小变更距离10m
private static final float minDistance = 10;
String tag = thistoString();
private LocationManager locationManager;
private LocationListener locationListener;
private final IBinder mBinder = new GPSServiceBinder();
public void startService() {
locationManager = (LocationManager) getSystemService(ContextLOCATION_SERVICE);
locationListener = new GPSServiceListener();
locationManagerrequestLocationUpdates(LocationManagerGPS_PROVIDER, minTime, minDistance,
locationListener);
}
public void endService() {
if (locationManager != null && locationListener != null) {
locationManagerremoveUpdates(locationListener);
}
}
@Override
public IBinder onBind(Intent arg0) {
// TODO Auto-generated method stub
return mBinder;
}

根据接口文档订阅MQTT消息，没有接收到消息；

使用>1、在这里下载Apollo服务器，下载后解压，然后运行apache-apollo-16\bin\apollocmd，输入create mybroker（名字任意取，这里是根据官网介绍的来取的）创建服务器实例，服务器实例包含了所有的配置，运行时数据等，并且和一个服务器进程关联。
2、create mybroker之后会在bin目录下生成mybroker文件夹，里面包含有很多信息，其中etc\apolloxml文件下是配置服务器信息的文件，etc\usersproperties文件包含连接MQTT服务器时用到的用户名和密码，后面会介绍，可以修改原始的admin=password，可以接着换行添加新的用户名密码。
3、打开cmd，运行…apache-apollo-16\bin\mybroker\bin\apollo-brokercmd run 开启服务器，可以在浏览器中输入>