MQ入门知识和简单消息发送配置

消息(Message)

消息:应用数据体和消息数据头。

消息是分为持久的和非持久的,持久就是队列管理器重启houston消息仍然存在。

队列

队列就是存放消息的容易,本地队列,远程队列,别名队列,模型队列。

本地队列:队列实体

远程队列和别名队列:一种队列的定义

模型队列:模型队列是为了创建动态队列

本地队列

1.初始化队列:用于消息触发,存放触发消息的队列

2.目标队列:消息的目的地,存放消息

3.死信队列:存放不能抵达的消息

4.传输队列:用于传递消息

队列管理器

消息队列的管理者,用来维护和管理消息队列。

通道:

通道时两个队列管理器之间的一种单向的点对点的通信连接,消息在通道中只能单向传输

下面在自己本地机子上安装WebSphereMQ7.1,然后建立两个队列管理器:

(1)创建两个队列管理器QM_CLIENT(1415),QM_SERVER(1414)

现在要实现的功能是从QM_SERVER向QM_CLIENT发送消息。

(2)在QM_SERVER上新建远程队列QR.C,设置远程队列、远程队列管理器,传输队列

(3)在QM_SERVER上新建传输队列QT.C

(4)在QM_SERVER上新建发送通道CHNL.S.C,设置连接名称,传输队列

(5)在QM_CLIENT上新建本地队列QL.C

(6)在QM_CLIENT上新建接收通道,队列管理器两端的通道名要一致CHNL.S.C

(7)在QM_SERVER端启动发送通道CHNL.S.C

(8)在QM_SERVER队列管理器远程队列:QR.C上放入测试消息,即可传输到QM_CLLIENT本地队列QL.C上

在QM_CLIENT队列管理器的本地队列QL.C可以浏览消息

到此就完成了一个消息的发送过程。

时间: 2024-08-06 15:38:55

MQ入门知识和简单消息发送配置的相关文章

RabbitMQ基础概念详解(一)——环境配置及模拟生产者和消费者简单消息发送

一.简介: RabbitMq 是实现了高级消息队列协议(AMQP)的开源消息代理中间件.消息队列是一种应用程序对应用程序的通行方式,应用程序通过写消息,将消息传递于队列,由另一应用程序读取 完成通信.而作为中间件的 RabbitMq 无疑是目前最流行的消息队列之一. AMQP,即Advanced Message Queuing Protocol,高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计.消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然.

activemq安装与简单消息发送接收实例

安装环境:Activemq5.11.1, jdk1.7(activemq5.11.1版本需要jdk升级到1.7),虚拟机: 192.168.147.131 [[email protected] software]# pwd /export/software [[email protected] software]# tar -zxvf apache-activemq-5.11.1-bin.tar.gz [[email protected] software]# mv apache-activem

rocketmq简单消息发送

有以下3种方式发送RocketMQ消息 可靠同步发送 reliable synchronous 可靠异步发送 reliable asynchronous 单向发送 one-way transmission 可靠同步发送 主要运用在比较重要一点消息传递/通知等业务 public class SyncProducer { public static void main(String[] args) throws Exception { DefaultMQProducer producer = new

MQ中将消息发送至远程队列的配置

MQ中将消息发送至远程队列的配置 摘自MQ资源管理器帮助文档V7 在开始学习本教程之前,您需要从系统管理员处了解标识网络上接收机器的名称:IP地址.MQ的端口号.队列管理器.接收(远程机器)或者是发送的队列(本地机器)名称. 消息传递如图示: 本教程介绍了如何设置一台计算机上的队列管理器 QM_ORANGE 与另一台计算机上的队列管理器 QM_APPLE 之间的消息传递.在第一台计算机上创建的消息被传递到第二台计算机上的队列 Q1(此队列被称为远程队列). 要点: 在本教程中,您将使用创建了队列

知识科普:IM聊天应用是如何将消息发送给对方的?(非技术篇)

1.引言 沟通是人类的最基本需求,复杂多变的沟通内容.沟通方式,正是人类文明之所以如此璀璨的关键所在. 在自然界中,要完成一件事情的沟通,我们可以直接通过声音传递给对方,这是再平常不过的事了(靠“吼”就能解决). 随着计算机的普及,互联网改变了我们的生活,甚至改变了我们的沟通方式.现在,“有什么事微信或QQ上找我”已经是很多的人口头禅了. 那么,作为不懂技术的普通人,有没有想过,你每次使用QQ或微这种IM聊天应用时,你所发送的消息,是如何被计算机送达给对方的?(这显然不可能靠“吼”解决 ^_^)

Spring Kafka和Spring Boot整合实现消息发送与消费简单案例

本文主要分享下Spring Boot和Spring Kafka如何配置整合,实现发送和接收来自Spring Kafka的消息. 先前我已经分享了Kafka的基本介绍与集群环境搭建方法.关于Kafka的介绍请阅读Apache Kafka简介与安装(一),关于Kafka安装请阅读Apache Kafka安装,关于Kafka集群环境搭建请阅读Apache Kafka集群环境搭建 .这里关于服务器环境搭建不在赘述. Spring Kafka整合Spring Boot创建生产者客户端案例 创建一个kafk

MQ入门总结(一)消息队列概念和使用场景

一.消息队列 消息即是信息的载体.为了让消息发送者和消息接收者都能够明白消息所承载的信息(消息发送者需要知道如何构造消息:消息接收者需要知道如何解析消息),它们就需要按照一种统一的格式描述消息,这种统一的格式称之为消息协议.所以,有效的消息一定具有某一种格式:而没有格式的消息是没有意义的. 而消息从发送者到接收者的方式也有两种.一种我们可以称为即时消息通讯,也就是说消息从一端发出后(消息发送者)立即就可以达到另一端(消息接收者),这种方式的具体实现就是我们已经介绍过的RPC(当然单纯的http通

rabbitMQ学习笔记(二) 简单的发送与接收消息 HelloWorld

首先要下载rabbitmq的javaClient库,然后加入到项目中,下载地址为:http://www.rabbitmq.com/releases/rabbitmq-java-client/v3.1.5/rabbitmq-java-client-bin-3.1.5.zip 1.发送消息 发送消息首先要获取与rabbitmq-server的连接,然后从渠道(chann)中指定的queue发送消息 , 不能定义两个queue名字相同,但属性不同 示例: Sender01.java 1 package

mq消息发送

钩子的注册: DefaultMQProducerImpl#registerSendMessageHook注册钩子处理类,可注册多个. public SendResult sendMessage( final String addr, final String brokerName, final Message msg, final SendMessageRequestHeader requestHeader, final long timeoutMillis, final Communicati