文档章节

AMQP

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

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

红薯 ⋅ 2013/04/03 ⋅ 0

RabbitMQ-C客户端使用说明

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

龙鸟 ⋅ 2012/09/20 ⋅ 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 ⋅ 0

Spring AMQP 2.0.0.M2 发布

Spring AMQP 2.0.0.M2 发布了。主要更改如下: AMQP-692:MessagingMessageListenerAdapter.invokeHandler() should include amqpMessage argument to the ListenerExecutionFailedException......

淡漠悠然 ⋅ 2017/01/05 ⋅ 0

Spring AMQP 1.7.4 发布,AMQP 消息解决方案

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

达尔文 ⋅ 2017/09/13 ⋅ 4

Spring AMQP 1.7.5 和 2.0.1 发布

Spring AMQP 1.7.5 和 2.0.1 发布了。两个版本都带来了系列 Bug 修复,和一些功能的增强。其中 2.0.1 版本是即将发布的 Spring Boot 2.0 M7 的基础。 主要更新内容: 2.0.1 Bug 修复 [AMQP-...

达尔文 ⋅ 2017/11/29 ⋅ 1

Spring AMQP 1.5.0 发布

Spring AMQP 1.5.0 发布,此版本更新内容如下: Bug 修复 [AMQP-532] - ConcurrentModificationException in PublisherCallbackChannelImpl 改进 [AMQP-527] - The org.springframework.amq......

淡漠悠然 ⋅ 2015/09/10 ⋅ 1

Spring AMQP 1.0 RC1 发布

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

红薯 ⋅ 2011/04/02 ⋅ 0

Spring AMQP 1.5.7 和 1.6.11 发布

Spring AMQP 1.5.7 和 1.6.11 已发布,Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的 POJO。 更新如下: 1.5.7 Bug [AMQP-...

淡漠悠然 ⋅ 2017/09/11 ⋅ 2

Spring AMQP 1.6.10 和 1.7.3 发布

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

淡漠悠然 ⋅ 2017/06/08 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

IDEA创建SpringMVC+Mybatis+Maven项目

视频如下(加载有点慢请见谅,服务器不太好): 视频

影狼 ⋅ 15分钟前 ⋅ 0

前阿里P8架构师:精准定制Java架构师学习计划!

可以说,Java是现阶段中国互联网公司中,覆盖度最广的研发语言,掌握了Java技术体系,不管在成熟的大公司,快速发展的公司,还是创业阶段的公司,都能有立足之地。 有不少朋友问,除了掌握J...

java高级架构牛人 ⋅ 18分钟前 ⋅ 0

zookeper学习

https://blog.csdn.net/u012152619/article/category/6470028

~少司命~ ⋅ 20分钟前 ⋅ 0

Spring MVC ,JSON,JQuery,不懂JQuery,跳过了

/spring-mvc-study/src/main/webapp/course_json.jsp <%@ page language="java" contentType="text/html; charset=UTF-8"pageEncoding="UTF-8"%><!DOCTYPE html PUBLIC "-//W3C//DTD ......

颖伙虫 ⋅ 20分钟前 ⋅ 0

2018上海云栖大会workshop-日志数据采集与分析对接

摘要: 日志数据采集与分析对接 课程描述 通过日志服务采集用户、数据库、业务等访问数据。演示对于业务日志分析与处理,程序日志查询与监控,打通日志与数据仓库对接案例。 日志种类 网站访...

阿里云云栖社区 ⋅ 21分钟前 ⋅ 0

mahout demo

package com.datamine.CollaborativeFiltering.mysql; import org.apache.mahout.cf.taste.impl.neighborhood.NearestNUserNeighborhood; import org.apache.mahout.cf.taste.impl.recommend......

xiaomin0322 ⋅ 22分钟前 ⋅ 0

red hat openstack 12配置要求

安装 openstack 之前,一般要规划整个系统中,到底要多少台机器来参与openstack, 根据rhosp12的官方文档: 最低要求是3台物理机,1台作为director,一台作为 controller ,一台作为computer....

tututu_jiang ⋅ 23分钟前 ⋅ 0

Rocket-Chip在GitHub上的各个源码

在github上通过搜索Rocket-chip可以得到36个结果:其中 https://github.com/freechipsproject/rocket-chip https://github.com/ucb-bar/riscv-boom https://github.com/ucb-bar/fpga-zynq (......

whoisliang ⋅ 29分钟前 ⋅ 0

【HAVENT原创】CentOS 6.5 下 Nginx 的安装与配置

nginx是轻量级的Web服务器、反向代理服务器及邮件服务器,具有占用内存少,并发能力强的优点,已被广泛应用。本文介绍目前最新版本 1.12.2 的安装。 各版本nginx下载地址:http://nginx.org/...

HAVENT ⋅ 35分钟前 ⋅ 0

查看linux系统重启之前的log -- last_kmsg

当 Linux Kernel 出现 BUG 的时候,后走入 panic flow,这个时候由于 Kernel 出现了严重的问题,adbd 也无法响应 adb 连接请求,这个时候想透过读取 Kernel Log Buffer 来看 Kernel Log 是不...

zyzzu ⋅ 36分钟前 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部