springboot+rabbitmq

Bertha 。 2022-02-17 14:46 241阅读 0赞

*  pom

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
     
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

*  配置

package com.master.rabbit;
     
    import org.springframework.amqp.core.AmqpAdmin;
    import org.springframework.amqp.core.Queue;
    import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
    import org.springframework.amqp.rabbit.connection.ConnectionFactory;
    import org.springframework.amqp.rabbit.core.RabbitAdmin;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
     
    
    @Configuration
    public class RabbitConfig {
     
        @Bean
        public Queue myQueue() {
            return new Queue("rabbit-queue");
        }
     
        @Bean
        public ConnectionFactory connectionFactory() {
            CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
            cachingConnectionFactory.setHost("192.168.111.103");
            cachingConnectionFactory.setUsername("springboot");
            cachingConnectionFactory.setPassword("123456");
            cachingConnectionFactory.setPort(5672);
            return cachingConnectionFactory;
        }
     
        @Bean
        public AmqpAdmin amqpAdmin() {
            return new RabbitAdmin(connectionFactory());
        }
     
        @Bean
        public RabbitTemplate rabbitTemplate() {
            return new RabbitTemplate(connectionFactory());
        }
    }

*  接受者

package com.master.rabbit;
     
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
     
    
    @Component
    public class Receiver {
     
        @RabbitListener(queues = "rabbit-queue")
        @RabbitHandler
        public void process(String message) {
            System.out.println("Receiver : " + message);
        }
     
    }

*  发送者

@Component
    public class Sender {
     
    	@Autowired
    	private RabbitTemplate rabbitTemplate;
     
    	public void send() {
    		String context = "hello " + new Date();
    		System.out.println("Sender : " + context);
    		this.rabbitTemplate.convertAndSend("rabbit-queue", context);
    	}
     
    }

springboot+rabbitmq

发表评论取消回复

还没有评论，来说两句吧...

相关阅读