MQ对于刚刚接触并且不懂的我 是那么的陌生,一搜这个关键词 只有ActiveMQ,这个东西,哎,因为专业术语的介绍这个东西真的还不如不介绍,这里借用
ActivitMQ简单介绍
这篇博客中的一段话的介绍吧。
1、首先ActiveMQ是什么东西?
答:ActiveMQ是一个易于使用的消息中间件。
2、消息中间件是什么?
答:相当于用于专递消息或数据的管子。
3、消息中间件有很多的用途和优点有?
(1). 将数据从一个应用程序传送到另一个应用程序,或者从软件的一个模块传送到另外一个模块;
(2). 负责建立网络通信的通道,进行数据的可靠传送。
(3). 保证数据不重发,不丢失
(4). 能够实现跨平台操作,能够为不同
操作系统
上的软件集成技工数据传送服务
4、MQ是什么?
首先简单的介绍一下MQ,MQ英文名MessageQueue,中文名也就是大家用的消息队列,干嘛用的呢,说白了就是一个消息的接受和转发的容器,可用于消息推送。(这是个长链喔,长链是什么不懂的就自己看着办了)。
ZeroMQ的使用
zeroMQ是一个开源的MQ,也比较好用,
github地址
。可能有些人觉得奇怪名字不是zeroMQ,但是人家开头就写了zeroMQ了,虽然名字不是zeromq(废话结束)。
public static void main(String args[]) {
ZMQ.Context context = ZMQ.context(1); //创创建包含一个I/O线程的context
ZMQ.Socket publisher = context.socket(ZMQ.PUB); //创建一个publisher类型的socket,他可以向所有订阅的subscriber广播数据
publisher.bind("tcp://*:5555"); //将当前publisher绑定到5555端口上,可以接受subscriber的订阅
while (!Thread.currentThread ().isInterrupted ()) {
String message = "fjs hello"; //最开始可以理解为pub的channel,subscribe需要订阅fjs这个channel才能接收到消息
publisher.send(message.getBytes());
publisher.close();
context.term();
public void run() {
// TODO Auto-generated method stub
ZMQ.Context context = ZMQ.context(1); //创建1个I/O线程的上下文
ZMQ.Socket subscriber = context.socket(ZMQ.SUB); //创建一个sub类型,也就是subscriber类型的socket
subscriber.connect("tcp://127.0.0.1:5555"); //与在5555端口监听的publisher建立连接
subscriber.subscribe("fjs".getBytes()); //订阅fjs这个channel
for (int i = 0; i < 100; i++) {
byte[] message = subscriber.recv(); //接收publisher发送过来的消息
System.out.println("receive : " + new String(message));
subscriber.close();
context.term();
}).start();
MQ
TT是一个轻量级的消息发布/订阅协议,它是实现基于手机客户端的消息推送服务器的理想解决方案。首先是配置
Android
端的依赖dependencies{
compile 'org.eclipse.paho:org.eclipse.paho.client.
mq
ttv3:1.1.0'
}添加权限:<uses-permission
android
:name="
android
.permission
由于andoid项目
中
有大量需要用到消息推送,平台端在实现消息推送选择active
mq
,为了能
使用
消息推送,决定研究一下如果在
android
端实现active
mq
的消息推送。
这个问题说难不难,说易也不易,平台端开发人员选择active
mq
并且认为active
mq
是用java的,所以认为
android
使用
它应该是很容易的,其实我很想告诉他们:"you are wrong!"。and
转载请注明出处:https://blog.csdn.net/l1028386804/article/details/82731262
基于
Android
的轻量级开源消息通信组件
Android
-
MQ
开源地址:https://github.com/sunshinelyz/
Android
-
MQ
基于
Android
的轻量级开源消息通信组件——
Android
-
MQ
自2017年开源以来,被大量应用到A...
最近项目
中
需要
使用
的小工具,牵扯到后台需要前后台做消息通信,和web端同事简单比较了下,决定
使用
MQ
进行通讯,之前App项目
中
使用
MQ
TT比较多,对于Rabbit
mq
只是简单的知道是一个后台经常用到的异步操作队列,当然既然要用,咱也不虚,简单了解了下,很快实现了功能,用起来挺方便的,这里简单作一下笔记。望后端大佬勿喷!~
MQ
文档地址: https://www.rabbit
mq
.com/tutorials/tutorial-one-java.html
Android
项目
中
引入Rabbit
mq
引入项目还是
压缩包
中
包含Client
Android
端和Service 端,Service端采用apache-active
mq
-5.13.3最新的版本。
Android
端采用
MQ
TT实现了消息的接收,接收消息的回调是messageArrived方法。
Server端的简要
使用
说明如下:
1、解压安装文件,执行\apache-active
mq
-5.13.3-bin\apache-active
mq
-5.13.3\bin\win64\wrapper.exe.
2、测试发送消息,打开本地服务器地址http://localhost:8161,登录服务器,默认用户名密码:admin,admin。登录以后就可以发送测试消息了,
Android
端可以接收。
Nano
MQ
(opens new window)是于2021年初发布的边缘计算开源项目,是面向物联网边缘计算场景的下一代轻量级高性能
MQ
TT消息服务器。
中
文官网:https://nano
mq
.io/docs/zh/latest/Github 仓库地址:https://github.com/e
mq
x/nano
mq
。
时间过得真快,转眼间接手的项目已经到了上线冲刺期了,所以最近几天一直很忙。在提前完成了
Android
端一部分开发任务后,抽出时间梳理一下关于Rabbit
MQ
消息队列在
Android
中
使用
的方法,希望能给在项目
中
需要Rabbit
MQ
的新手一点帮助。关于Rabbit
MQ
是什么?
MQ
全称为Message Queue, 消息队列(
MQ
)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针...
1.什么是
MQ
TT协议
MQ
TT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议。有可能成为物联网的重要组成部分。该协议支持所有平台,几乎可以把所有联网物品和外部连接起来,被用来当做传感器和致动器(比如通过Twitter让房屋联网)的通信协议2.
MQ
TT协议的特点
MQ
TT协议是为大量计算能力有限,且工作在低带宽、不可靠的网络的远