AMQP 消息解决方案 Spring AMQP

Apache
Java .NET
跨平台
2010-07-18
红薯

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

示例代码:

public static void main(final String... args) throws Exception {

    ConnectionFactory cf = new CachingConnectionFactory();

    // set up the queue, exchange, binding on the broker
    RabbitAdmin admin = new RabbitAdmin(cf);
    Queue queue = new Queue("myQueue");
    admin.declareQueue(queue);
    TopicExchange exchange = new TopicExchange("myExchange");
    admin.declareExchange(exchange);
    admin.declareBinding(
        BindingBuilder.bind(queue).to(exchange).with("foo.*"));

    // set up the listener and container
    SimpleMessageListenerContainer container =
            new SimpleMessageListenerContainer(cf);
    Object listener = new Object() {
        public void handleMessage(String foo) {
            System.out.println(foo);
        }
    };
    MessageListenerAdapter adapter = new MessageListenerAdapter(listener);
    container.setMessageListener(adapter);
    container.setQueueNames("myQueue");
    container.start();

    // send something
    RabbitTemplate template = new RabbitTemplate(cf);
    template.convertAndSend("myExchange", "foo.bar", "Hello, world!");
    Thread.sleep(1000);
    container.stop();
}
加载中

评论(0)

暂无评论

Spring AMQP 2.1.2 发布

Spring AMQP 2.1.2 发布。 d272015 (master) Upgrade dependencies to prepare for release ed6f76b More Sonar Fixes 50d6265 Sonar polishing of previous commit 3ca85b9 Add missing @nu...

2018/11/28 09:18

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

Spring AMQP 2.1.0 已发布,Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案。 更新内容: c71252f (HEAD -> master) Upgrade to SF-5.1.1 2480b17 AMQP-836: SMLC queuesChanged() vi...

2018/10/16 17:24

Spring AMQP 1.7.9,2.0.5 和 2.1.0.M1 版本发布

Spring AMQP 1.7.9,2.0.5 和 2.1.0.M1 已发布。 1.7.9 更新内容: Upgrade Spring Framework to 4.3.18 AMQP-824: Name for deferredCloseExec thread pool Fix test race condition Fix Si...

2018/07/27 09:08

Spring AMQP 2.0.4 发布,Spring 的 AMQP 编程模型

Spring AMQP 2.0.4 和 1.7.8 发布了,更新内容如下: 2.0.4 Change Log: 54b7dd8 Add more debug/trace logging 3a55ede Add licence and notice to all artifacts 00bd3dc AMQP-818: Fix C...

2018/06/15 11:09

Spring AMQP 2.0.3 和 1.7.7 发布,包含大量更新

Spring AMQP 2.0.3 和 1.7.7 发布,包含大量更新。 2.0.3 更新: 6dc3228 Fix serial compiler warning on new exception 2180db2 Align versions with Boot/Platform.Cairo 44dcb37 Upgrade ...

2018/04/08 14:35

Spring AMQP 1.7.6 和 2.0.2 发布,Bug 修复

Spring AMQP 1.7.6 和 2.0.2 已发布,具体更新如下: Spring AMQP 1.7.6 1e8986e Decrease logging level to the WARN f786c5b AMQP-796: Fix Admin Transaction f78d916 AMQP-794: CRError...

2018/01/30 16:59

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 07:38

Spring AMQP 2.0.0 正式版发布

Spring AMQP 2.0.0 正式版发布了。主要更新内容如下: 完整的 Java 8 和 Spring Framework 5.0 支持; 包含实用测试工具的新的 sring-rabbit-junit 工件,包括 BrokerRunning JUnit @Rule; a...

2017/10/06 07:06

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

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

2017/09/13 07:30

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 10:33

没有更多内容

加载失败,请刷新页面

3
回答
spring-amqp+docker+rabbitmq连接每10分钟左右断开次

大神好,项目使用spring amqp为客户端,rabbitmq放在centos7的docker容器中。现在发现客户端和服务器的长连接会每隔10分钟左右断...

2018/06/19 08:26
3
回答
RabbitMQ框架下,需要一个同步消息机制接收高响应的消息,有这个功能吗?

对于一些远程消息需要在方法中同步获取消息结果,然后继续向下执行。求解,因为目前框架中已有RabbitMQ,所以问下能否实现

2016/09/04 17:18
1
回答
spring amqp 发布确认的问题

public void confirmCallback(RabbitTemplate template,final CountDownLatch thre...

2016/06/03 10:44
1
回答
spring amqp

spring amqp一执行 amqpTemplate.convertAndSend("messages", message.getValue()); 就...

没有更多内容

加载失败,请刷新页面

没有更多内容

消息队列RabbitMQ与Spring集成,消费者监听队列报错

错误信息: java.lang.NoClassDefFoundError: org/springframework/util/backoff/BackOff at java.lang.Class.getDeclaredMethods0(Native Method) at java.lang.Class.privateGetDeclaredMe...

2018/07/02 09:41
414
0
侦听消息队列的Message Listener类

Spring AMQP 是基于 Spring 框架的AMQP消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的 POJO的消息监听等,简化了我们对于RabbitMQ相关程序的开发。 Spring AMQP包含...

2018/06/08 15:34
42
0
rabbitMQ精讲系列第十八篇 高级整合应用第一篇

在本章学习中,我们主要是和应用整合的。下面来看看本章我们主要内容: 整合spring AMQP和spring boot及spring cloud整合。以及在整合中需要注意及工作中踩过的坑。如同如下图: 本文主要内容...

08/10 08:59
2
0
Spring AMQP 源码分析MessageListener

### 准备 ## 目标 了解 Spring AMQP 如何实现异步消息投递(推模式) ## 前置知识 《RabbitMQ入门_05_多线程消费同一队列》 ## 相关资源 Quick Tour for the impatient:<http://docs.spring...

2018/08/12 17:02
157
0
Spring的生态

Spring不止是提供了IOC、AOP的功能,还提供了大量的基于Spring的项目,拿来用就行了,用于一站式开发,大大降低了开发的难度。 下面列举下主要的一些Spring的生态项目: Spring Boot:一站式快速开...

2018/08/30 10:08
5
0
springboot 学习9

Spring Data 、Spring Security 、Spring Integration 、Spring AMQP, Spring Session 、Spring Batch 等...

2018/10/15 11:05
2
0
spring其他产品

spring Boot spring Cloud Spring Secuirity Spring Data Spring AMQP

01/23 10:30
1
0
spring Messaging

34. Messaging 消息 34.2 AMQP Advanced Message Queuing Protocol(AMQP)是一个用于面向消息的中间件的平台中立的线级协议。Spring AMQP项目将核心Spring概念应用到基于AMQP的messaging解决...

04/29 13:41
17
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部