使用spring-amqp结合使用rabbitmq - html/css语言栏目:

maven 依赖包配置如下: [ html]   <dependencies>       <dependency>           <groupId>org.springframework.amqp</groupId>           <artifactId>spring-rabbit</artifactId>           <version>1.2.0.RELEASE</version>       </dependency>   </dependencies>     通过spring 获得到连接,并发送消息 [java]   public static void main(final String... args) throws Exception {          AbstractApplicationContext ctx =           new ClassPathXmlApplicationContext("context.xml");       RabbitTemplate template = ctx.getBean(RabbitTemplate.class);       template.convertAndSend("Hello, world!");       Thread.sleep(1000);       ctx.destroy();   }     context.xml 配置如下: [html]   <rabbit:connection-factory id="connectionFactory" />      <rabbit:template id="amqpTemplate" connection-factory="connectionFactory"       exchange="myExchange" routing-key="foo.bar"/>      <rabbit:admin connection-factory="connectionFactory" />      <rabbit:queue name="myQueue" />   <!--路由设置 将队列绑定,属于topic类型-->   <rabbit:topic-exchange name="myExchange">       <rabbit:bindings>           <rabbit:binding queue="myQueue" pattern="foo.*" />       </rabbit:bindings>   </rabbit:topic-exchange>   <!-- 监听类设置-->      <rabbit:listener-container connection-factory="connectionFactory">       <rabbit:listener ref="foo" method="listen" queue-names="myQueue" />   </rabbit:listener-container>      <bean id="foo" class="foo.Foo" />     Foo 类 此类用于监听消息 [java]   public class Foo {          public void listen(String foo) {           System.out.println(foo);       }   }    
返回顶部
跳到底部

Copyright 2011-2024 南京追名网络科技有限公司 苏ICP备2023031119号-6 乌徒帮 All Rights Reserved Powered by Z-BlogPHP Theme By open开发

请先 登录 再评论,若不是会员请先 注册