active mq怎么在多系统间调用

中凯_凯哥java 发布于 2017/11/14 14:50
阅读 224
收藏 0

描述:

使用的是spring boot框架。单个系统,假设叫做系统B(系统内部)使用active mq 生产者、消费者都是正常的已经实现。现在有其他系统的时候,怎么调用。比如A系统是生产者,想要把消息发送给系统B。让B来消费。这种怎么实现?

加载中
0
尚浩宇
尚浩宇

A系统只管发,B系统只管接啊,以前都在一个系统里,现在拆出去代码不还是那些代码吗?

尚浩宇
尚浩宇
@凯哥java 回复@凯哥java : 那看下队列是否被消费,然后看消费端是否连接到队列
中凯_凯哥java
中凯_凯哥java
回复 @尚浩宇 : 使用的是一对一的模式。现在就是消费之端接收不到
尚浩宇
尚浩宇
回复 @凯哥java : MQ有两种消息模式,一种是队列,这是一对一的,一个消息只能有1个消费者处理,另一种是topic,类似群发的,我不知道你创建的是哪一种,如果是第二种,只要你这个topic是已经创建好的,消费者连接上后,就会开会拿生产者的数据
中凯_凯哥java
中凯_凯哥java
您好,我就是把MQ相关的复制到另一个项目中,然后两个项目都启动,mq也启动。A系统发送消息但是B系统不能获取到。
0
JasonWcx
JasonWcx
实现a的内容生产即可,因为b中已有消费环节
中凯_凯哥java
中凯_凯哥java
可能是消费端也就是B没有配置好。一直监听不到。收不到生产者发布的消息
0
JasonWcx
JasonWcx
那就要看你的程序结构了,对消息管道来说,a,b都是客户端,只不过一个生产,一个消费
中凯_凯哥java
中凯_凯哥java
解决了。是消费者端B没有配置好
0
哎呦-又忘了
哎呦-又忘了
A在发消息到队列里面,B在消费这个队列就好了嘛,amq 似乎一个消费者只能消费一个队列。所以b里面得再有个消费者
中凯_凯哥java
中凯_凯哥java
是的。但是B没有配置好。所以消费不了
0
huojianguo
huojianguo

问题概述:1.系统之间的交流。2.通道技术

目前集中实现的系统交流是RPC技术,通过发布服务,完成系统之间的交流。生产/消费模式。是目前常用的前段与后端交流的一种手段。目前其中是Kafka中间插件。你说的问题,就是配置kafka就行。

中凯_凯哥java
中凯_凯哥java
kafka没用过。不过,我这个问题是消费者B端没有配置好
0
中凯_凯哥java
中凯_凯哥java

引用来自“JasonWcx”的评论

那就要看你的程序结构了,对消息管道来说,a,b都是客户端,只不过一个生产,一个消费

消费者端B没有配置好

返回顶部
顶部