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