文档章节

AMQP

慕容若冰
 慕容若冰
发布于 2016/12/09 16:30
字数 174
阅读 13
收藏 0
  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
博文 44
码字总数 9774
作品 0
广州
程序员
Spring AMQP 1.2.0.M1 发布

Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的 POJO。同时有 Java 和 .NET 的版本。 Spring AMQP 1.2.0 发布了首个里程碑版...

红薯
2013/04/03
948
0
RabbitMQ-C客户端使用说明

rabbitmq-c是一个用于C语言的,与AMQP server进行交互的client库,AMQP协议为版本0-9-1。rabbitmq-c与server进行交互前需要首先进行login操作,在操作后,可以根据AMQP协议规范,执行一系列操...

龙鸟
2012/09/20
0
0
Spring AMQP 1.6.0 M2 和 1.5.5 发布

Spring AMQP 1.6.0 M2 和 1.5.5 发布了,Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的 POJO。同时有 Java 和 .NET 的版本...

oschina
2016/03/26
2.4K
0
Spring AMQP 1.7.4 发布,AMQP 消息解决方案

Spring AMQP 1.7.4 发布了,Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的 POJO。 更新内容: Bug [AMQP-762] - Semaphore...

达尔文
2017/09/13
539
4
RabbitMQ第三课 基本概念和exchange

Rabbitmq使用必须理解的一些概念 (转自:http://www.linuxidc.com/Linux/2013-11/92591.htm) channel:通道,amqp支持一个tcp连接上启用多个mq通信通道,每个通道都可以被作为通信流。 produc...

fengyuzaitu
07/19
0
0

没有更多内容

加载失败,请刷新页面

加载更多

利用责任链模式设计一个拦截器

前言 近期在做 Cicada 的拦截器功能,正好用到了责任链模式。 这个设计模式在日常使用中频率还是挺高的,借此机会来分析分析。 责任链模式 先来看看什么是责任链模式。 引用一段维基百科对其...

编程SHA
13分钟前
0
0
IDE,SATA,SCSI,SAS,FC,SSD说明与区别

DE是俗称的并口,SATA是俗称的串口,这两种硬盘是个人电脑和低端服务器常见的硬盘。SCSI是”小型计算机系统专用接口”的简称,SCSI硬盘就是采用这种接口的硬盘。SAS就是串口的SCSI接口。一般...

mskk
15分钟前
0
0
MySQL面试题集锦

什么是数据库索引?索引有哪几种类型?什么是最左前缀原则?索引算法有哪些?有什么区别? 索引是对数据库表中一列或多列的值进行排序的一种结构。一个非常恰当的比喻就是书的目录页与书的正...

老道士
51分钟前
0
0
使用 LogStash 归集日志

elastic 官网: https://www.elastic.co/ 为了便于集中查看多台主机的业务日志,使用 Filebeat, Redis, Logstash的方式进行收集: (1) Filebeat 监控日志文件的变化, 将新增部分写入redis中, 每...

ouhoo
54分钟前
0
0
java序列化(六) - protostuff序列化

添加依赖 <dependency> <groupId>io.protostuff</groupId> <artifactId>protostuff-core</artifactId> <version>1.5.9</version> </de......

晨猫
今天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部