AMQP
AMQP
慕容若冰 发表于1年前
AMQP
  • 发表于 1年前
  • 阅读 13
  • 收藏 0
  • 点赞 0
  • 评论 0

腾讯云 技术升级10大核心产品年终让利>>>   

  1. 安装Erlang
  2. 安装RabbitMQ
  3. 新建Spring Boot项目,依赖为AMQP
  4. 发送信息及目的地定义
    package com.amqp;
    
    import org.springframework.amqp.core.Queue;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.annotation.Bean;
    
    /**
     * 发送消息及目的地定义
     */
    @SpringBootApplication
    public class AmqpApplication implements CommandLineRunner{
    
       //注入Spring Boot 自动配置好的RabbitTemplate
       @Autowired
       RabbitTemplate rabbitTemplate;
    
       public static void main(String[] args) {
          SpringApplication.run(AmqpApplication.class, args);
       }
    
       //定义目的地,即队列,名称为my-queue
       @Bean
       public Queue wiselyQueue() {
          return new Queue("my-queue");
       }
    
       @Override
       public void run(String... args) throws Exception {
          //向队列my-queue发送消息
          rabbitTemplate.convertAndSend("my-queue", "来自RabbitMQ的问候");
       }
    }
  5. 消息监听
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    /**
     * 消息监听
     * Created by Administrator on 2016/12/9.
     */
    @Component
    public class Receiver {
        @RabbitListener(queues = "my-queue")//queues属性指定要监听的目的地
        public void receiveMessage(String message) {
            System.out.print("Received <" + message + ">");
        }
    }
  6. 运行
共有 人打赏支持
粉丝 0
博文 43
码字总数 9774
×
慕容若冰
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: