相关文章推荐
好帅的领带  ·  Java消息队列--ActiveMq ...·  1 年前    · 

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协议是为大量计算能力有限,且工作在低带宽、不可靠的网络的远