是否有与MQ/JMS setTargetClient等效的MQ/XMS？ - 腾讯云开发者社区 - 腾讯云

开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

jboss EAP 6.2 + Message Drive Bean(MDB) 整合IBM Webshpere MQ 7.5

上一篇我们知道了消息驱动Bean的基本用法，实际大型分布式企业应用中，往往会采用高性能的商业Queue产品，比如IBM Webshpere MQ(目前最新版本是7.5 )，下面讲解下如何在Jboss EAP...6.2 版本上整合Webshpere MQ 7.5 一、修改jboss的standalone-full.xml a) 添加IBM的resource-adapters 找到的安装目录 C:\Program Files (x86)\IBM\WebSphere MQ\java\lib\jca 下有一个wmq.jmsra.rar文件，把它复制到 %JBOSS_HOME%\standalone...\deployments 下，jboss启动后，将自动部署该rar 注：rar包的版本必须与MQ相符（即：如果你要监听MQ 7.5的队列消息，则该rar必须是MQ 7.5自带的）附: 7.5版wmq.jmsra.rar...activation-config> 46 47 48 这二种配置方式完全等效

2.5K8 0

消息中间件MQ科普

MQ的使用场景什么时候不使用MQ 既然MQ是互联网分层架构中的解耦利器，那所有通讯都使用MQ岂不是很好？这是一个严重的误区，调用与被调用的关系，是无法被MQ取代的。...小湖学院系统创建订单场景，创建订单时需要查找课程基本信息，订单服务调用课程服务，课程服务的执行结果直接影响创建订单的结果，此处的“订单服务”与“课程服务”就必须使用调用关系，而不能使用MQ通信。...采用MQ的优点是： 1）上游执行时间短 2）上下游逻辑+物理解耦，除了与MQ有物理连接，模块之间都不相互依赖 3）新增一个下游消息关注方，上游不需要修改任何代码【典型场景三：上游关注执行结果，但执行时间很长...为了避免雪崩，常见的优化方案有两种： 1）业务上游队列缓冲，限速发送 2）业务下游队列缓冲，限速执行问：如何缓冲流量？使用MQ做消息缓冲。...数据驱动的任务依赖上游不关心多下游执行结果异步返回执行时间长缓冲流量，削峰填谷 AMQP和JMS MQ是消息通信的模型，并不是具体实现。现在实现MQ的有两种主流方式：AMQP、JMS。 ? ?

1K3 0

您找到你想要的搜索结果了吗？

是的

没有找到

MQ系列（0）——什么是MQ

当有能力去消费这些水的时候再去从 “蓄水池” 放水。实际的过程是——请求数据先发到 mq ，应用程序监听mq 并消费消息。...mq 协议及产品 mq 协议有两种，jms 和 AMQP 。通常而言提到JMS（Java MessageService）实际上是指 JMS API 。...JMS consumer/subscriber ：JMS消息消费者 JMS message：消息，在各个JMS client传输的对象； JMS queue：Provider存放等待被消费的消息的地方...JMS topic：一种提供多个订阅者消费消息的一种机制；在MQ中常常被提到，topic模式。...queue和exchange的bind有consumer来决定。相对而言，AMQP的消息队列使用的更为广泛。

1.8K2 0

消息队列概述

2、应用程序解耦合 MQ相当于一个中介，生产方通过MQ与消费方交互，它将应用程序进行解耦合。 3、削峰填谷如订单系统，在下单的时候就会往数据库写数据。...AMQP 和 JMS MQ是消息通信的模型；实现MQ的大致有两种主流方式：AMQP、JMS。...AMQP 与 JMS 区别 JMS是定义了统一的接口，来对消息操作进行统一；AMQP是通过规定协议来统一数据交互的格式 JMS限定了必须使用Java语言；AMQP只是协议，不规定实现方式，因此是跨语言的...协议，erlang语言开发，稳定性好 RocketMQ：基于JMS，阿里巴巴产品 Kafka：类似MQ的产品；分布式消息系统，高吞吐量特性 ActiveMQ RabbitMQ RocketMQ...，在很多公司得到应用；有较多的文档；各种协议支持较好基于erlang开发，所以并发能力很强，性能极其好，延时很低;管理界面较丰富 MQ功能比较完备，扩展性佳只支持主要的MQ功能，像一些消息查询，消息回溯等功能没有提供

1.3K2 0

消息中间件RabbitMQ

提高了应用程序的响应时间。 2.2 应用程序解耦合 MQ相当于一个中介，通过它让生产者与消费者交互，将应用程序进行解耦合。...但使用了MQ之后，限制消费消息的速度为1000，但是这样一来，高峰期产生的数据势必会被积压在MQ中，高峰就被“削”掉了。...AMQP 和 JMS MQ是消息通信的模型；实现MQ的大致有两种主流方式：AMQP、JMS。...与 JMS 的本质差别： AMQP不从API层进行限定，而是直接定义网络交换的数据格式。...3.3 AMQP 与 JMS 区别 JMS 是定义了统一的接口，来对消息操作进行统一； AMQP是通过规定协议来统一数据交互的格式 JMS 限定了必须使用Java语言； AMQP只是协议，不规定实现方式

7262 0

MQ概述

MQ优势 MQ相当于一个中介，生产方通过MQ与消费方交互，它将应用程序进行解耦合。系统的耦合性越高，容错性就越低，可维护性就越低。使用 MQ 使得应用间解耦，提升容错性和可维护性。...常见的 MQ 产品目前业界有很多的 MQ 产品，例如 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等，也有直接使用 Redis 充当消息队列的案例，而这些消息队列产品...AMQP 和 JMS 实现MQ的两种主流方式：AMQP、JMS。...基于此协议的客户端与消息中间件可传递消息，遵循此协议，不收客户端和中间件产品和开发语言限制。2006年，AMQP 规范发布。类比HTTP。...JMS 是 JavaEE 规范中的一种，类比JDBC。很多消息中间件都实现了JMS规范，例如：ActiveMQ。RabbitMQ 官方没有提供 JMS 的实现包，但是开源社区有。

2.6K2 0

消息队列(一)

如果现在又有E系统也需要A系统发送数据，那么A系统就要修改代码，刚修改完，C系统因需求变更又不需要A发送数据了，A又要修改，这种错综复杂的系统严重耦合，A系统还要时刻考虑数据接收方是否是健康的系统，如果挂掉了要怎么办等等问题...AMQP和JMS AMQP和JMS是学习消息队列很难绕开的，先看一下它们是什么意思。...基于此协议的客户端与消息中间件可传递消息，并不受客户端中间件不同产品、不同的开发语言等条件的限制。 JMS：通常讲的 JMS(Java MessageService)实际上是JMS API。...常见的几个MQ： ActiveMQ：基于JMS RabbitMQ：基于AMQP协议，erlang语言开发，稳定性好 RocketMQ：基于JMS，阿里开发，目前由Apache基金会维护 Kafka：分布式消息系统...丢失消息，一般RabbitMQ有消息持久化机制，可以将消息写入磁盘，哪怕RabbitMQ挂了也可以读取磁盘中存储的消息然后恢复。

6771 0

ActiveMQ --- 入门篇

一、什么是MQ？ MQ，中文名字叫做消息中间件。既然是中间件，那么就说明它左边有东西，右边也有东西。那么左边是什么？右边又是什么呢？MQ在中间能干嘛呢？看看下面的例子。...目的地有以下两种：队列queue(点对点); 主题topic(发布与订阅); 1、点对点传输：所谓点对点传输，可以理解为发私信。你发了一条消息给你女朋友，只有你女朋友能收到。...点对点的目的地是queue，发布与订阅的目的地是topic，每条消息可以有多个消费者；生产者和消费者有时间上的关联，订阅了某个topic，只能消费你订阅之后的消息，说简单就是，关注了你公众号的人，他不能收到在他关注你之前的消息...JMS就是天上飞的理念，而各种MQ就是这种理念的落地实现。比如activeMQ、rocketMQ等，都要遵循JMS这个规范。...然后再运行生产者发送信息，此时，不论消费者是否还在线，都会接收到消息，不在线的话，下次连接的时候，会把没有收过的消息都接收下来。

4.4K2 0

RabbitMQ设计原理解析

这时候，第一种方式是A每隔一段时间来查询一次，看B是否执行完，这是拉的方式；第二种方式是A提供一个回调地址，B执行完之后回调A，这是推的方式；第三种就是使用MQ，A使用MQ给B发消息，B处理完再回一个消息...应用解耦 MQ实现了逻辑解耦+物理解耦。逻辑上，将请求和结果处理分开了；物理上，系统只用与MQ通信。听起来，MQ要优雅很多，但是上面提到异步处理的三种方式的前两种，现在也多很常见。...那是因为MQ是有代价的，那就是需要一套MQ设施。做开放平台，用户之间的唯一设施就是互联网，这时候更依赖双方的协议约定，所以前两种异步处理方式不会被MQ取代。...JMS支持 RabbitMQ不支持JMS协议。这个很好理解。因为JMS是Java消息服务，提供了消息传递的Java标准API。而RabbitMQ是Erlang写的，对Java的支持会弱一些。...AMQP只是统一了数据交换的标准格式，与语言无关。核心部分核心概念所有的MQ都由生产者、消费者和broker(队列)三部分组成。但是不同的实现，根据核心思想不同，内部结构也各有特色。

7732 0

SpringBoot 整合 gradle 集成ActiveMQ

1.springBoot 2.3.1.RELEASE 2.gradle 5.6 3.activeMQ 2.3.1.RELEASE 第一步：首先在build.gradle中导入activeMQ的依赖...admin password: admin pool: enabled: false max-connections: 50 #默认包名安全（支持序列化与反序列化...= "test.queue") public void receiveQueue(String text) { System.out.println("消费者：来源于生产者对列的消息...成功"); return "浏览器上测试mq成功"; } } 在浏览器上输入 http://localhost:8085/test-mq/浏览器上测试MQ 得到结果： ?...in com.es.basedata.mq.MqProducer required a bean of type 'org.springframework.jms.core.JmsMessagingTemplate

9992 0

剖析1条JMS消息

javax.jms.Message接口有对应的getJMSDestination()方法。...Message接口有对应的get,set方法。...在接收时设置消息被消费时的事务ID JMSXRcvTimestamp long MQ在接收时设置 JMS把消息发送的消费者的时间 JMSXState int MQ 假设存在一个消息仓库，该消息仓库包含每个发送到消费者...这个状态仅仅用于在仓库中查询， JMS没有对应的API 2.3MQ特定的消息用于支持厂商的私有特性。我在工作中没有使用到，不做介绍。...读取的顺序与写入的顺序一致。

1.8K7 0

一篇文章让你了解JMS以及中间件之ActiveMQ

JMS(Java Message Service) JMS的组成特点 JMS provider 实现JMS接口和规范的消息中间件，也就是我们的MQ服务器 JMS producer 消息生产者创建和发送...JMS不要求MQ严格按照这十个优先级来发送消息，但必须保证加急消息要优先于普通消息默认4级 JMS MessageID（幂等性会用到）唯一识别每个消息的标识由MQ产生消息体发送和接收的消息体类型必须一直对应...持久订阅才能恢复或重新派送一个未签收的消息 JMS编码总体架构（类似JDBC编码） JavaEE Active MQ MQ中间件的落地产品有哪些？...基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件的限制。...3个 get /activemq/leveldb-stores/00000000000 # 查看elected 是否有值有值的为master null为slaver 测试 // 生产者

2.3K3 0

Message Queue消息队列基本原理

是大型分布式系统不可缺少的中间件。注意：为了简便，下文中除了文章标题，一律使用 MQ 简称。一、为何用 MQ MQ 比较核心的优点有 3 个：解耦、异步、削峰。...MQ 重复消费不可怕，可怕的是没有应对机制，可以借鉴的思路有：如果是写数据库，可以先根据主键查询，判断数据是否已存在，存在则更新，不存在则插入；如果是写 Redis，set 操作，由于天然具有幂等性...在 EJB 架构中，有消息 bean 可以无缝的与 JM 消息服务集成。在 J2EE 架构模式中，有消息服务者模式，用于实现消息与应用直接的解耦。...深入学习 JMS 对掌握 JAVA 架构，EJB 架构有很好的帮助，消息中间件也是大型分布式系统必须的组件。本次分享主要做全局性介绍，具体的深入需要大家学习，实践，总结，领会。...参考资料大型网站架构系列：分布式 MQ（一）大型网站架构系列：MQ（二）分布式开放 MQ(RocketMQ)的原理与实践阿里 RocketMQ 优势对比 advanced-java 之 MQ

3.7K3 0

干货｜SpringBoot JMS（ActiveMQ）API实践应用详解

ActiveMQ实现了JMS标准并提供了很多附加的特性。本文将带大家详细介绍ActiveMQ的API的使用。公众号：「浅羽的IT小屋」 1. JMS的概念？...MQ的实现产品「实现产品：」 ActiveMQ RabbitMQ RockerMQ Kafka（这个设计的初衷是做分布式的日志的，后来因为日志有严格的顺序问题，这个时候人们就用Kafka来做消息队列了...（消费者） package com.qy.mq.queue; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms...package com.qy.mq.topic; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*;...package com.qy.mq.topic; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*;

5873 0

Kafka实战(1)-为何大厂都选择Kafka作为消息队列

这MQ有啥用？ MQ是一组规范。利用这组规范可以在不同系统间传递语义准确的消息，实现松耦合的异步式数据传递。系统A发送消息给MQ，系统B从MQ中读取A发送的消息。...不过JMS太有名以至于很多主流消息引擎系统都支持JMS规范，比如RabbitMQ、Kafka。Kafka也未完全遵照JMS规范。为什么要使用MQ?...所以更常见的办法是引入像Kafka这样的消息引擎系统来对抗这种上下游系统TPS的错配以及瞬时峰值流量。引入Kafka后。上游订单服务不再直接与下游子服务交互。...下游的各个子服务订阅Kafka中的对应主题，并实时从该主题的各自分区（Partition）中获取到订单消息进行处理，从而实现上游订单服务与下游订单处理服务解耦。...常见数据流：通过数据库通过服务调用（REST/RPC）通过异步消息传递（消息引擎，如Kafka） RPC和MQ相似，远程调用一个服务也可看做是一个事件，但不同在于： MQ有自己的buffer，能够对抗过载

8704 0

SpringBoot之Jms

前言:JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信...Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。...//用户名 spring.activemq.password= //密码注意：如果没有设置mq的单独服务地址默认会将在项目启动时启动一个单独的MQ服务。...这个时候需要保证该服务不会重启，如果正在异步通信中关闭MQ会造成所有队列中的消息丢失。...: Started SendJmsApplication in 1.969 seconds (JVM running for 2.309) 7.配置activemq activemq有一个

1.6K1 0

快速学习-RabbitMQ基本介绍

将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。提高了应用程序的响应时间。用程序解耦合 MQ相当于一个中介，生产方通过MQ与消费方交互，它将应用程序进行解耦合。...总结：AMQP是一套公开的消息队列协议，最早在2003年被提出，它旨在从协议层定义消息通信数据的标准格式，为的就是解决MQ市场上协议不统一的问题。...RabbitMQ就是遵循AMQP标准协议开发的MQ服务。官方：http://www.amqp.org/ JMS是什么？ ?...总结： JMS是java提供的一套消息服务API标准，其目的是为所有的java应用程序提供统一的消息通信的标准，类似java的 jdbc，只要遵循jms标准的应用程序之间都可以进行消息通信。...它和AMQP有什么不同，jms是java语言专属的消息服务标准，它是在api层定义标准，并且只能用于java应用；而AMQP是在协议层定义的标准，是跨语言的。

5072 0

消息中间件MQ之ActiveMQ学习总结(上)

ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现，尽管JMS规范出台已经是很久的事情了，但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。...JMS开发的基本步骤： ? 消息模式：点对点：一对一 ? 订阅：一对多 ?...(false, Session.AUTO_ACKNOWLEDGE); 这里的boolean就是是否开启事务，后面的就是签收方式为自动签收构造方法：构造方法： ?...总结：这种三种角色的技术理念，类比dubbo的提供者，注册中心，消费者 redis的主从机制等理念，技术选型需要有消息订阅，降低系统负担，异步解耦的痛点，从而并不是所有业务场景都适合与MQ。...ActiveMQ的官方文档： http://activemq.apache.org/components/classic/documentation 对比与所有中间件的功能，维度，可理解其他产品的使用，

7571 0

RabbitMQ简单模式

二、项目搭建JMS由于MQ产品很多，操作方式各有不同，于是JAVA提供了一套规则——JMS，用于操作消息中间件。...JMS即Java消息服务（JavaMessage Service）应用程序接口，是一个Java平台中关于面向消息中间件的API。JMS是JavaEE规范中的一种，类比JDBC。...很多MQ产品都实现了JMS规范，例如ActiveMQ。RabbitMQ官方并没有实现JMS规范，但是开源社区有JMS的实现包。...* 参数2：是否自动签收，如果设置为false，则需要手动确认消息已收到，否则MQ会一直发送消息 * 参数3：Consumer的实现类，重写该类方法表示接受到消息后如何消费具体代码如下：...* 参数2：是否自动签收，如果设置为false，则需要手动确认消息已收到，否则MQ会一直发送消息 * 参数3：Consumer的实现类，重写该类方法表示接受到消息后如何消费

2831 0

ActiveMQ入门代码

Hello world程序演示：生产者： package com.mq.helloworld; import javax.jms.Connection; import javax.jms.ConnectionFactory...connection.start(); //第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般设置为手动签收...=null){ connection.close(); } } } 消费者： package com.mq.helloworld; import...connection.start(); //第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般设置为自动签收...时就需要认证了，在生产者和消费者第一步中将default_user、default_password换成配置文件中自定义的username和password即可访问MQ。

5612 0

点击加载更多

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭