Spring整合RabbitMQ进行消息队列开发

墨蓝 2022-08-20 11:16 207阅读 0赞

Spring AMQP提供了org.springframework.amqp.core.AmqpTemplate来发送与接收消息。RabbitMQ是Spring AMQP官方示例中所用的默认AMQP实现。

在项目pom.xml文件中添加依赖：

<dependency>
    	<groupId>com.rabbitmq</groupId>
    	<artifactId>amqp-client</artifactId>
    	<version>3.4.1</version>
    	</dependency>
    <dependency>
    	<groupId>org.springframework.amqp</groupId>
    	<artifactId>spring-rabbit</artifactId>
    	<version>1.4.0.RELEASE</version>
    </dependency>

Spring配置文件：

<bean id="rabbitMQHandler" class="com.taotao.solr.rabbit.RabbitMQHandler" />
    
    </beans>

java代码：

生产者：

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;
    
    /**
     * 消费者
     *
     */
    public class Foo {
    
        //具体执行业务的方法
        public void listen(String foo) {
            System.out.println("消费者： " + foo);
        }
    }