<bean id="stockServiceGateway" class="org.springframework.amqp.rabbit.stocks.gateway.RabbitStockServiceGateway">
<property name="rabbitTemplate">
<rabbit:template connection-factory="connectionFactory" routing-key="app.stock.request"
message-converter="jsonMessageConverter"/>
</property>
<property name="defaultReplyTo" value="fanout://broadcast.responses/"></property>
</bean>
<rabbit:fanout-exchange name="broadcast.responses">
<rabbit:bindings>
<rabbit:binding queue="tradeQueue"></rabbit:binding>
</rabbit:bindings>
</rabbit:fanout-exchange>
太粗心了,之前将第二个的name写成了broadcast.response,少写了一个s,导致测试通不过。
spring-amqp有一个官方示例Stock Trading(股票交易),文档在Spring AMQP - Reference Documentation,代码放置在GitHub上,名叫spring-amqp-samples,该项目原来是CS架构,C端为Swing开发,后来改为BS架构,变成了Web项目,因此看代码发现src/main/resources下的client-*.xml没有用时不要觉得奇怪。简单将Stock Trading运行过程描述一下:
1. "/trade":POST方式,将页面提交过来的参数封装成TradeRequest并将其作为参数调用下面的spring-rabbit服务网关,最后将这个TradeRequest返回给浏览器。
2. spring-rabbit服务网关:将收到的TradeRequest发送到Default Exchange,routing key为"app.stock.request"(消息将发送到app.stock.request这个队列),同时指定消息返回的exchange为"fanout://broadcast.responses/"。
3. Queue:app.stock.request
4. spring-rabbit监听器:监听app.stock.request队列,每收到一个TradeRequest,经过一系列的处理,生成TradeResponse,将之发送到exchange"broadcast.response"。
5. Fanout Exchange:broadcast.responses,binding(绑定)Queue:tradeQueue
6. Queue:tradeQueue
7. spring-rabbit监听器:监听tradeQueue队列,每收到一个TradeResponse,将之缓存并移除缓存中已经超时的TradeResponse。
分享到:
相关推荐
spring-amqp,spring-retry,spring-rabbit
spring-cloud-config + spring-cloud-bus-amqp实现分布式集群配置动态更新,可更新实例对象,包含源码包+Rabbitmq安装包和安装说明
压缩包包含两部分,spring-amqp为java版的Spring AMQP的实现,spring-amqp-sample为补充版(也可作为快速入门的)
spring-amqp 相关jar , 最近在学spring amqp是时候找jar找了好长时间,现在找全了,在这分享给大家。
spring-amqp-2.0.3.RELEASE.jar
spring-amqp-reference-1.6.1.RELEASE
spring-amqp文档.zip
spring-amqp-1.4.0.RELEASE.jar 官方正版jar包下载
spring-amqp-reference
rabbitmq 路由spring-amqp 配置实现
spring-amqp,Spring 的消息中间件
JMeter-Rabbit-AMQP解决中文乱码问题,加入编码格式UTF-8的编码格式,发送MQ的时候传中文可以正常显示
springboot-rabbitmq-amqp
spring-amqp-logback/log4jBest practice for logging with AMQP+LOGBACK/log4j (使用Rabbitmq+logback/log4j来中心化存储你的业务日志)包含 日志发布端(logback and log4j) 和 日志接收端 两个最佳实践例子。...
activemq-amqp-5.8.0.jar
spring-amqp-java-8 在 Java 8 上运行的示例项目( ) 要求 RabbitMQ 3.4.2 Java 8 Java 7 Maven 3 跑步 确保您正在运行 Java 8 ( java -version ) mvn install java -jar target/spring-amqp-java-8-0.1.0....
Laravel开发-laravel-amqp 用于laravel和lumen发布和使用消息的AMQP包装器
imixs-workflow.zip,imixs工作流rest服务api为imixs jee工作流组件提供了一个servlet实现。
标签:apollo-amqp-1.7.jar,apollo,amqp,1.7,jar包下载,依赖包
该项目包含一些补充示例,向您展示如何开始使用Spring和AMQP。制作说明首先安装代理(版本2.3.1或更高版本)。 然后从GIT克隆,然后使用Maven(2.1。*): $ git clone ...$ mvn installSpringSource ToolSuite用户...