zoukankan      html  css  js  c++  java
  • springboot使用rabbitmq

    话不多少 上来就是干

    如果你想直接可以使用,可以直接参考项目代码 github源代码

    首先引入依赖

                <dependency>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-amqp</artifactId>
    	</dependency>
    

    application.properties配置信息

    #默认端口配置
    

    server.port=8080

    rabbit配置

    spring.rabbitmq.host=127.0.0.1
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    spring.rabbitmq.virtual-host=/

    @Component
    public class ProduceRabbitComponent {
    
    @Autowired
    private RabbitTemplate rabbitTemplate;
    
    @Scheduled(cron = "0 * * * * *") // 每分钟发送一次数据信息
    public void sendRabbitMessage() {
            String message = UUID.randomUUID().toString();
            System.out.println(message);
            rabbitTemplate.convertAndSend("queue_one", message);
            rabbitTemplate.convertAndSend("queue_two", message);
        }
    
     }
  • 相关阅读:
    01背包问题
    数据库并发的问题
    NGINX
    代理模式(静态代理)
    桥接模式
    组合模式
    jmeter-xpath Assertion断言
    jmeter-xpath Extractor 使用
    jmeter-html链接解析器使用
    js-浏览器对象
  • 原文地址:https://www.cnblogs.com/licunzhi/p/9342072.html
Copyright © 2011-2022 走看看