基于mqtt协议的消息推送服务器,基于 MQTT 协议的推送服务
一、简述
MQTT(Message Queuing Telemetry Transport,消息队列遥测传输协议),是一种基于发布/订阅(publish/subscribe)模式的“轻量级”通讯协议,该协议构建于TCP/IP协议上,由IBM在1999年发布。MQTT最大优点在于,可以以极少的代码和有限的带宽,为连接远程设备提供实时可靠的消息服务。作为一种低开销、低带宽占用的即时通讯协议,使其在物联网、小型设备、移动应用等方面有较广泛的应用。
MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。在很多情况下,包括受限的环境中,如:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。
二、apache-Apollo 服务器搭建
1.将下载后的 压缩包进行解压:
apollo.png
2.打开 cmd 运行 bin/apollo.cmd
apollo.png
3.创建一个服务器实例
image.png
4.在服务中打开 apollo 服务
image.png
初始账号: admin 密码:password
6.进入apollo控制台
image.png
进入此页面说明服务器成功搭建
三、服务端推送和客户端监听
SeverClass
package com.mqtt;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
import org.eclipse.paho.client.mqttv3.MqttTopic;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class ServerMQTT {
//tcp://MQTT安装的服务器地址:MQTT定义的端口号
public static final String HOST = "tcp://0.0.0.0:61613";
//定义一个主题
public static final String TOPIC = "message";
//定义MQTT的ID,可以在MQTT服务配置中指定
private static final String clientid = "server11";
private MqttClient client;
private MqttTopic topic11;
private String userName = "admin"; //非必须
private String passWord = "password"; //非必须
private MqttMessage message;
/**
* 构造函数
* @throws MqttException
*/
public ServerMQTT() throws MqttException {
// MemoryPersistence设置clientid的保存形式,默认为以内存保存
client = new MqttClient(HOST, clientid, new MemoryPersistence());
connect();
}
/**
* 用来连接服务器
*/
private void connect() {
MqttConnectOptions options = new MqttConnectOptions();
options.setCleanSession(false);
options.setUserName(userName);
options.setPassword(passWord.toCharArray());
// 设置超时时间
options.setConnectionTimeout(10);
// 设置会话心跳时间
options.setKeepAliveInterval(20);
try {
client.setCallback(new PushCallback());
client.connect(options);
topic11 = client.getTopic(TOPIC);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
*
* @param topic
* @param message
* @throws MqttPersistenceException
* @throws MqttException
*/
public void publish(MqttTopic topic , MqttMessage message) throws MqttPersistenceException,
MqttException {
MqttDeliveryToken token = topic.publish(message);
token.waitForCompletion();
System.out.println("message is published completely! "
+ token.isComplete());
}
/**
* 启动入口
* @param args
* @throws MqttException
*/
public static void main(String[] args) throws MqttException {
ServerMQTT server = new ServerMQTT();
server.message = new MqttMessage();
server.message.setQos(1); //保证消息能到达一次
server.message.setRetained(true);
server.message.setPayload("这是服务器发出的信息的内容".getBytes());
server.publish(server.topic11 , server.message);
System.out.println(server.message.isRetained() + "------ratained状态");
}
}
ClientClass
package com.mqtt;
import java.util.concurrent.ScheduledExecutorService;
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.MqttTopic;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class ClientMQTT {
public static final String HOST = "tcp://0.0.0.0:61613";
public static final String TOPIC1 = "message";
private static final String clientid = "client11";
private MqttClient client;
private MqttConnectOptions options;
private String userName = "admin"; //非必须
private String passWord = "password"; //非必须
@SuppressWarnings("unused")
private ScheduledExecutorService scheduler;
private void start() {
try {
// host为主机名,clientid即连接MQTT的客户端ID,一般以唯一标识符表示,MemoryPersistence设置clientid的保存形式,默认为以内存保存
client = new MqttClient(HOST, clientid, new MemoryPersistence());
// MQTT的连接设置
options = new MqttConnectOptions();
// 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录,设置为true表示每次连接到服务器都以新的身份连接
options.setCleanSession(false);
// 设置连接的用户名
options.setUserName(userName);
// 设置连接的密码
options.setPassword(passWord.toCharArray());
// 设置超时时间 单位为秒
options.setConnectionTimeout(10);
// 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线,但这个方法并没有重连的机制
options.setKeepAliveInterval(20);
// 设置回调
client.setCallback(new PushCallback());
MqttTopic topic = client.getTopic(TOPIC1);
//setWill方法,如果项目中需要知道客户端是否掉线可以调用该方法。设置最终端口的通知消息
//options.setWill(topic, "close".getBytes(), 2, true);
client.connect(options);
//订阅消息
//订阅消息
client.subscribe(TOPIC1, 1);
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws MqttException {
ClientMQTT client = new ClientMQTT();
client.start();
}
}
server
server
client
client
基于mqtt协议的消息推送服务器,基于 MQTT 协议的推送服务相关推荐
- 微软软件推送服务器,向 UWP 应用添加推送通知 - Azure Mobile Apps | Microsoft Docs
向 Windows 应用添加推送通知 06/25/2019 本文内容 概述 本教程介绍如何向 Windows 快速入门项目添加推送通知,以便每次插入一条记录时,向设备发送一条推送通知. 如果不使用下载 ...
- 苹果服务器消息转发,iphone-与APNS服务器进行交互以将推送通知发...
最好的方法是使用API??,例如以下服务提出的建议: >选择一个Saas API,将其连接到PHP / MySQL应用程序 >城市飞艇 > Pushwoosh > Wonder ...
- 苹果微信推送服务器错误,接入WxPusher微信推送服务出现错误:Content type application/x...
背景 使用WxPusher微信推送服务 ,可以及时的将服务的一些运行异常信息,发送到自己的微信上,方便了解服务的运行状态(PS:这个服务是免费的). 你可以在这里看到WxPusher微信推送服务的接入 ...
- tcp协议用来提供什么服务器,关于TCP协议,我想你应该懂了!
TCP是什么?程序员 TCP(Transmission Control Protocol 传输控制协议)是一种面向链接(链接导向)的.可靠的. 基于IP的传输层协议.TCP在IP报文的协议号是6.TC ...
- 【行情获取】通过WebSocket使用ws协议获取黄金、外汇实时行情(行情自动推送,方便实现数据驱动下的自动交易)
文章目录 前言 一.WebSocket是什么? 二.使用准备 1. 引入websocket-client库 2. 获取websocket行情数据 三.获取黄金行情的完整代码 总结 前言 一.WebSo ...
- 基于服务器的p2p协议实现,基于P2P协议的文件服务器技术.PDF
基于P2P协议的文件服务器技术.PDF 第 15 卷 第 6 期 微 机 发 展 Vol. 15 No. 6 2005 年 6 月 Microcomputer Development J un. 20 ...
- php消息实时推送技术,基于HTTP协议之WEB消息实时推送技术原理及实现
很早就想写一些关于网页消息实时推送技术方面的文章,但是由于最近实在忙,没有时间去写文章.本文主要讲解基于 HTTP1.1 协议的 WEB 推送的技术原理及实现.本人曾经在工作的时候也有做过一些用到网页 ...
- Android 二维码被扫后接收通知(使用MQTT协议实现消息推送)
现如今扫码付款和收款已经很便利了,比如超市买完东西付款时有两种方式 : 顾客可以出示付款码给收银员扫码收款,也可以由顾客扫描超市的收款码进行付款 .两种方式在付款完成后超市端会进行语音播报收到xx元. ...
- springboot+websocket+sockjs进行消息推送【基于STOMP协议】
1.浅谈WebSocket WebSocket是在HTML5基础上单个TCP连接上进行全双工通讯的协议,只要浏览器和服务器进行一次握手,就可以建立一条快速通道,两者就可以实现数据互传了.说白了,就是打 ...
最新文章
- 开始Go开发之旅-Golang架构师之路系列实战
- linux qt应用程序全屏,QT在ubuntu下实现界面全屏,侧边栏隐藏,上边栏隐藏【实例】...
- php print r用法,php中echo(),print(),print_r()用法
- python对于字典d d.get(x、y)_给定字典 d ,哪个选项对 d.get(x, y) 的描述是正确的?_学小易找答案...
- 爬虫介绍+Jupyter Notebook
- windows驱动安装卸载的实用小工具-InstDrv.exe
- struts2面试题大全含答案
- 迁移oracle数据库,简简单单的Oracle数据库迁移方法
- JS将sql的dateTime格式数据例如:Wed Sep 30 00:00:00 CST 2020 字符串转换成2020-09-30 00:00:00时间格式
- Nginx 限流的天坑
- 海信e5k和e5h区别 对比评测 哪个好
- Spark DAG与RDD
- Greenplum【部署 04】GPSS扩展安装并使用GPKafka实现Kafka数据导入Greenplum数据库(安装包网盘分享)
- STM32—DAC配置
- 记码农十周年(20110214--20210214)
- Python LAC使用
- CSS学习案例(16):网易云音乐导航栏
- word2vec产生的词向量中出现空格和回车,会导致ValueError: invalid vector on line3 (is this really the text format)
- 京东科技寒假实习前端一面面经
- Android文件系统的结构及目录用途、操作方法 整理
热门文章
- 导入训练好的决策树文件_决策树在sklearn中的实现
- Thinkphp框架中D()和M()的区别
- 将本地工程上传到github
- C#.NET 大型企业信息化系统集成快速开发平台 4.2 版本 - 防止脱库、防止篡改数据...
- 用场景来规划测试工作
- 软件项目质量保证——编码规范
- UA SIE545 优化理论基础 函数凸性的一些有趣的判断方法
- VC2019无法打开文件msvcrtd.lib和Spectre 缓解库相关问题
- 图解windbg查看Win7结构体
- springboot中关闭eureka server中已注册服务列表自我保护配置