定时刷新页面需要activemq吗(如何使用camel对两个mq级联)

本文目录
如何使用camel对两个mq级联
著名的EIP实现框架Camel最早起源于ActiveMQ内的一些基于消息的集成需求,然后逐渐发展成为一个ActiveMQ的子项目,最后这一块的功能越来越完善,就成为了Apache的顶级项目。
所以,从一开始到现在,ActiveMQ与Camel这两个项目一直都是紧密联系的,可以非常方便的整合使用:比如在ActiveMQ的配置文件中直接按照Spring的配置方式使用Camel来实现ActiveMQ与其他外部系统或中间件的集成。而ActiveMQ中的一些简单的集成功能也越来越倾向于直接去掉或者移植到Camel环境中去实现。
环境:ActiveMQ 5.9.0、RabbitMQ3.3.0、
一、ActiveMQ与ActiveMQ的集成
实现一个简单的从一个Queue到另一个Queue的消息转发。
1. 在activemq.xml中加一句:《import resource="camel.xml"/》
2. 加一个简单路由,从队列example.A转发消息到队列example.B,camel.xml的内容为:
view plaincopy
《span style="font-size:14px;"》《beans
***隐藏网址***
***隐藏网址***
xsi:schemaLocation="
***隐藏网址***
***隐藏网址***
***隐藏网址***
《route》
《description》Example Camel Route《/description》
《from uri="activemq:example.A"/》
《to uri="activemq:example.B"/》
《/route》
《/camelContext》
《bean id="activemq"class="org.apache.activemq.camel.component.ActiveMQComponent" 》
《property name="connectionFactory"》
《beanclassbeanclass="org.apache.activemq.ActiveMQConnectionFactory"》
《property name="brokerURL"value="vm://localhost?create=true"/》
《property name="userName"value="${activemq.username}"/》
《property name="password" value="${activemq.password}"/》
《/bean》
《/property》
《/bean》
《/beans》《/span》
***隐藏网址***
4. 点击Send To,发送一个消息到example.A,刷新页面,可以看到消息已经被转发:
二、ActiveMQ与RabbitMQ集成
***隐藏网址***
Ø 从RabbitMQ路由消息到ActiveMQ
1. Camel里添加AMQP的路由如下:
view plaincopy
《span style="white-space:pre"》 《/span》《route》
《from uri="rabbitmq://localhost/t?username=guest&password=guest&exchangeType=topic&autoDelete=false&queue=t"/》
《to uri="activemq:example.fromRMQ"/》
《/route》
2. 复制camel中的camel-rabbitmq-2.13.0.jar 和rabbitmq-java-client中的rabbitmq-client.jar到apache-activemq-5.9.0\lib\camel下。
3. 重启ActiveMQ,在rabbitmq的控制台可以看到自动创建的exchange为t,
如何使用activemq 管理页面
ActiveMQ持久化消息的二种方式; 1、持久化为文件 这个装ActiveMQ时默认就是这种,只要设置消息为持久化就可以了。涉及到的配置和代码有: producer.Send(request,MsgDeliveryMode.Persistent,level,TimeSpan.MinValue); 2、持久化为MySql 首先需要把MySql的驱动放到ActiveMQ的Lib目录下,我用的文件名字是:mysql-connector-java-5.0.4-bin.jar 接下来修改配置文件 在配置文件中的broker节点外增加 从配置中可以看出数据库的名称是activemq,需要手动在MySql中增加这个库。 然后重新启动消息队列,会发现多了3张表 1:activemq_acks 2:activemq_lock 3:activemq_msgs
quartz调度的任务怎么操作页面,就是想用Java类的方法去给操作前台页面
你的设计可能有些问题
从“网页上显示出来处理的结果”判断,你应该是BS架构
BS架构是 请求/响应 的处理模式,即必须有请求,才有响应
BS架构要想 后台驱动前台,必须加中间件,如MQ,比较好用的是ActiveMQ
可以做折中变更:
针对: BS架构是 请求/响应 的处理模式,即必须有请求,才有响应
在quartz调度任务结束后,将处理信息结果入库,包括
A. 调度的执行记录,如结果、任务号、时间
B. 调度的业务执行结果, 和业务相关的信息
在前台页面,通过js定时执行某方法,扫描上面A信息,然后把成功的A对应的B(处理的结果
)取出来,展示在前台,一般使用Ajax比较好
亲,如果回答满意,请即时采纳,你的理解是我回答的动力,谢谢

更多文章:
capital会计里面表示什么(会计里的capital=asstes具体是什么意思)
2025年11月26日 23:15
使用yum安装mysql教程(怎么样使用yum来安装mysql)
2026年4月19日 01:00
substring按字节截取(用C#写一个截取字符串的函数,输入为一个字符串和字节数,输出为按字节截取的字符串 但是要保证汉字不被)
2026年4月24日 15:00
进制转换公式代表字母(二进制八进制十进制十六进制符号是什么)
2025年7月6日 02:45
websocket浏览器兼容(websocket怎样兼容ie8)
2025年5月24日 04:30
except for与except和besides的区别口诀(except for与except和besides的区别是什么)
2025年9月10日 09:30
linux配置与管理web服务器(高分请教如何搭建Linux下的web服务器)
2025年12月1日 02:00
for index怎么使用(能帮我说一下那个for(int i : index)有什么作用吗,其他的都看明白了,唯独那个)
2026年1月24日 22:30
seeyou开头的一首英文歌(有的首英文歌的歌词,开头是See you See me.这首歌叫什么名字,谢了哈)
2026年4月29日 19:30
在asp中if语句的语法是什么?asp中replace的具体用法!!
2025年9月30日 19:15
怎么看有没有装jdk(在windows系统下怎么查看有没有安装jdk)
2025年11月1日 17:15
protected与private的区别(VC++中的public,private,protected的区别,说得通俗点)
2026年8月25日 22:45
smart keyboard(smartkeyboard怎么关闭语音输入‘)
2025年7月12日 11:00










