当前位置:编程学习 > html/css >>

使用spring-amqp结合使用rabbitmq

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);  
    }  
}  
 
补充:web前端 , HTML/CSS  ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,