首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 软件管理 > 软件架构设计 >

spring-amqp官方示范Stock Trading

2012-07-01 
spring-amqp官方示例Stock Tradingrabbit:fanout-exchange namebroadcast.responsesrabbit:bindings

spring-amqp官方示例Stock Trading

<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。

?

热点排行