Spring RabbitMQ使用

╰+哭是因爲堅強的太久メ 2022-05-16 04:58 222阅读 0赞

项目地址  
[http://spring.io/projects][http_spring.io_projects]

提供了对AMOP的支持  
提供了RabbitMQ的实现  
[http://spring.io/projects/spring-amqp][http_spring.io_projects_spring-amqp]  
![这里写图片描述][70]

### 配置文件 ###

第一步，定义连接工厂  
第二步，定义模板，可以指定交换机或队列  
第三步，定义队列、交换机、以及完成队列和交换机的绑定  
第四步，定义监听  
第五步，定义管理，用于管理队列、交换机等

Durable  
表示对持久化的配置  
True，表示持久化  
False，表示非持久化

### 生产者 ###

package cn.itcast.rabbitmq.spring;
    
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.context.support.AbstractApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    public class SpringMain {
        public static void main(final String... args) throws Exception {
            AbstractApplicationContext ctx = new ClassPathXmlApplicationContext(
                    "classpath:spring/rabbitmq-context.xml");
            //RabbitMQ模板
            RabbitTemplate template = ctx.getBean(RabbitTemplate.class);
            //发送消息
            template.convertAndSend("Hello, world!");
            Thread.sleep(1000);// 休眠1秒
            ctx.destroy(); //容器销毁
        }
    }

### 消费者 ###

package cn.itcast.rabbitmq.spring;
    
    /** * 消费者 * @author zhijun * */
    public class Foo { 
    
        //具体执行业务的方法
        public void listen(String foo) {
            System.out.println("消费者： " + foo);
        }
    }

### 运行 ###

![这里写图片描述][70 1]

[http_spring.io_projects]: http://spring.io/projects
[http_spring.io_projects_spring-amqp]: http://spring.io/projects/spring-amqp
[70]: /images/20220516/40e821167b204937893a36df137c3cf8.png
[70 1]: /images/20220516/d0d3d0f365c445ccb641b9da2107f247.png