文档章节

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
RabbitMQ第三课 基本概念和exchange

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

fengyuzaitu
07/19
0
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

没有更多内容

加载失败,请刷新页面

加载更多

下一页

基于TP5的微信的公众号获取登录用户信息

之前讲过微信的公众号自动登录的菜单配置,这次记录一下在TP5项目中获取自动登录的用户信息并存到数据库的操作 基本的流程为:微信设置自动登录的菜单—>访问的URL指定的函数里获取用户信息—...

月夜中徘徊
55分钟前
0
0
youTrack

package jetbrains.teamsys.license.runtime; 计算lis package jetbrains.ring.license.reader; 验证lis 安装后先不要生成lis,要把相关文件进行替换 ring-license-checker-1.0.41.jar char......

max佩恩
58分钟前
0
0
12.17 Nginx负载均衡

Nginx负载均衡 下面的dig看到可以返回2个IP,就是解析出来的IP,这样我们可以做负载均衡。 dig www.qq.com 1.vim /usr/local/nginx/conf/vhost/fuzai.conf 2.添加如下配置 upstream qq //定义...

芬野de博客
今天
0
0
SSE(Server Send Event 服务端发送事件)

package com.example.demo.controller;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.RequestMapping;import org.springframe......

Canaan_
今天
0
0
jvm调优

1.jvm运行模式 client模式:启动快,占用内存少,jit编译器生成代码的速度也更快. server模式:主要优势在于代码优化功能,这个功能对于服务器应用而言尤其重要. tiered server模式:结合了client与...

Funcy1122
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部