springboot下mqtt简单使用

概述

mqtt是一个物联网协议。
简单来说它由三大块组成：

服务端（转发消息的server）
生产者（发送消息）
消费者（接收消息）

简单来说就是一个轻量级的收发消息的东西。发消息的人也可以消费消息。
消息由中间的消息服务器转发给对应的订阅者。

代码demo

下面是自己运行的demo，copy的官网
https://www.emqx.io/docs/zh/v5.0/development/java.html#paho-java-%E4%BD%BF%E7%94%A8%E7%A4%BA%E4%BE%8B

package com.fchan;import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;/*** ClassName: MqttClient* Description:* date: 2022/11/1 18:01** @author fchen*/
public class MqttSendClient {public static void main(String[] args){String subTopic = "nb_fchan/#";String pubTopic = "nb_fchan/1";String content = "Hello World";int qos = 2;String broker = "tcp://broker.emqx.io:1883";String clientId = "emqx_test";MemoryPersistence persistence = new MemoryPersistence();try {MqttClient client = new MqttClient(broker, clientId, persistence);// MQTT 连接选项MqttConnectOptions connOpts = new MqttConnectOptions();connOpts.setUserName("emqx_test");connOpts.setPassword("emqx_test_password".toCharArray());// 保留会话connOpts.setCleanSession(true);// 设置回调client.setCallback(new ClientOnMessageCallback());// 建立连接System.out.println("Connecting to broker: " + broker);client.connect(connOpts);System.out.println("Connected");System.out.println("Publishing message: " + content);// 订阅client.subscribe(subTopic);// 消息发布所需参数MqttMessage message = new MqttMessage(content.getBytes());message.setQos(qos);client.publish(pubTopic, message);System.out.println("Message published");client.disconnect();System.out.println("Disconnected");client.close();System.exit(0);} catch (MqttException me) {System.out.println("reason " + me.getReasonCode());System.out.println("msg " + me.getMessage());System.out.println("loc " + me.getLocalizedMessage());System.out.println("cause " + me.getCause());System.out.println("excep " + me);me.printStackTrace();}}}package com.fchan;import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;/*** ClassName: OnMessageCallback* Description:* date: 2022/11/1 18:06** @author fchen*/
public class ClientOnMessageCallback implements MqttCallback {@Overridepublic void connectionLost(Throwable cause) {// 连接丢失后，一般在这里面进行重连System.out.println("连接断开，可以做重连");}/*** QoS0，At most once，至多一次；* QoS1，At least once，至少一次；* QoS2，Exactly once，确保只有一次。* @param topic* @param message* @throws Exception*/@Overridepublic void messageArrived(String topic, MqttMessage message) throws Exception {// subscribe后得到的消息会执行到这里面System.out.println("接收消息主题:" + topic);System.out.println("接收消息Qos:" + message.getQos());System.out.println("接收消息内容:" + new String(message.getPayload()));}@Overridepublic void deliveryComplete(IMqttDeliveryToken token) {System.out.println("deliveryComplete---------" + token.isComplete());}
}

springboot下mqtt简单使用相关推荐

Springboot实现MQTT通信
目录一.MQTT简介 1.MQTT协议 2.MQTT协议特点二.MQTT服务器搭建三.使用Springboot整合MQTT协议 1.在父工程下创建一个Springboot项目作为消息的提供者 1 ...
SpringBoot + Spring Security 简单入门
这篇文章主要介绍了SpringBoot + Spring Security 简单入门 Spring Security 基本介绍这里就不对Spring Security进行过多的介绍了,具体的可以参考 ...
Eclipse 工具上Springboot项目的简单增删改查的搭建
目录一.为嘛子要学习Springboot 二.简单的说下springboot 三.咱们对比看看呗四.开始操作,建项目 1.建一个maven项目 2.pom.xml 依赖以及配置文件 ①简单的依 ...
springboot+uniapp实现简单注册登录
springboot+uniapp实现简单注册登录前言后端新建springboot项目配置数据库建表,写对应类写接口,写对应xml文件封装返回信息,封装UUID Service层 Con ...
繁易MQTT简单操作说明
繁易MQTT简单操作说明一,emqttd的安装与部署 1,下载emqttd软件安装包 https://www.emqx.io/ 2,下载解压之后,cmd进入软件bin目录下,输入emqttd con ...
SpringBoot +WebSocket实现简单聊天室功能实例
SpringBoot +WebSocket实现简单聊天室功能实例) 一.代码来源二.依赖下载三.数据库准备(sql) 数据库建表并插入sql 四.resources文件配置 application ...
1112_Vue+SpringBoot+Mybatis的简单员工管理项目
Vue+SpringBoot+Mybatis的简单员工管理项目本文项目参考自:https://github.com/boylegu/SpringBoot-vue https://www.cnblog ...
Docker下redis与springboot三部曲之三：springboot下访问redis哨兵
在< Docker下redis与springboot三部曲之二:安装redis主从和哨兵>一文中,我们在docker下搭建了redis主从和哨兵,本章我们开发一个基于springboot的 ...
SpringBoot下的策略模式，消灭了大量的ifelse，真香！
前言项目中有这样一个场景,在公园放置了用来拍摄人像的识别杆,根据用户在不同识别杆之间采集的图象来计算用户的运动距离.由于涉及到许多公园,每个公园的布局不同,识别杆之间距离不同,算法也不同.但代码中每 ...

springboot下mqtt简单使用

概述

代码demo

springboot下mqtt简单使用相关推荐

最新文章

热门文章