正文 

当前位置： 首页 > 源码 >

Spring 集成 pubsub 与 Spring amqp RabbitMQ pubsub

     2023-02-26     59

关键词：

【中文标题】Spring 集成 pubsub 与 Spring amqp RabbitMQ pubsub【英文标题】：Spring integration pubsub vs Spring amqp RabbitMQ pubsub 【发布时间】：2015-12-24 02:24:51 【问题描述】：

我正在开发一个 MicroBlog spring mvc hibernate 应用程序。我需要实现像 twitter 这样的发布订阅功能。

我正在使用 RabbitMQ 通过 Spring AMQP 抽象进行消息传递。

我在网上看到的所有pubsub examples 都涉及

春季集成

Spring AMQP 和 RabbitMQ

我对 Spring-Integration 进行了更多研究，发现即使不使用 RabbitMQ，也可以使用它实现发布订阅。

现在我的问题是

为什么我需要将 Spring Integration 与 [Spring AMQP & RabbitMQ] 一起使用来实现发布订阅功能。为什么我不能只使用带有 Rabbit 的 Spring AMQP 来做到这一点？

Spring 集成是否提供任何附加功能？

我的 Spring AMQP 和 RabbitMQ 配置

<rabbit:connection-factory id="connectionFactory" virtual-host="/" host="localhost" 
username="guest" password="guest"/>

<rabbit:admin connection-factory="connectionFactory" />

<rabbit:queue name="UserPostpublishQueue" />

<fanout-exchange name="broadcastUserPosts" xmlns="http://www.springframework.org/schema/rabbit">
    <bindings>
        <binding queue="UserPostpublishQueue"/>
    </bindings>
</fanout-exchange>

<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="broadcastUserPosts" 
queue="UserPostpublishQueue"/>

</beans>

在我的控制器中测试代码

@Autowire
private AmqpTemplate amqpTemplate;

try
        amqpTemplate.convertAndSend(post);
        Post receivedPost = (Post)amqpTemplate.receiveAndConvert();
        System.out.println("received Post "+receivedPost);
        catch(AmqpException e)
            //deal with exception

【问题讨论】：

为什么不关注一些谷歌链接，也不阅读两者？... 如果 Google 上有足够的内容，我一开始就不会提出这个问题。如果您不知道答案，为什么不停止对问题投反对票。 【参考方案1】：

Spring Integration 实现了来自 http://www.enterpriseintegrationpatterns.com/books1.html 的模式，同时使用 AMQP/RabbitMQ 作为其众多传输之一。

我了解spring-amqp 更多的是 AMQP 客户端功能。如果你不想使用弹簧。然后我们有一个普通的 java 客户端：https://www.rabbitmq.com/java-client.html

【讨论】：

Spring boot：将消息推送到每个请求的特定主题

】Springboot：将消息推送到每个请求的特定主题【英文标题】：Springboot:pushmessagetospecifictopicforeachrequest【发布时间】：2020-04-0123:55:02【问题描述】：我正在使用pubsub与springboot的集成，我的配置类如下所示：@ConfigurationpublicclassPubSub... 查看详情

集成框架 - Apache Camel 与 Spring 集成？ [关闭]

】集成框架-ApacheCamel与Spring集成？[关闭]【英文标题】：Integrationframework-apachecamelvsspringintegration?[closed]【发布时间】：2016-10-2614:30:59【问题描述】：我正在评估一个基于EIP（企业集成模式）用于我的应用程序的集成框架。我有apac... 查看详情

quartz与spring集成

待写...Job类是由Quartz实例化的，并非由Spring管理，如果Job类中使用了Spring的依赖注入(@Autowired,@Resource等)，是无法注入的。如何解决？请参考这篇博客：http://www.cnblogs.com/daxin/p/3608320.html 查看详情

spring与mybatis集成

Spring集成MyBatis​将MyBatis与Spring进行整合，主要解决的问题就是将SqlSessionFactory对象交由Spring来管理。所以，该整合，只需要将SqlSessionFactory的对象生成器SqlSessionFactoryBean注册在Spring容器中，再将其注入给Dao的实现... 查看详情

spring与mybatis集成

Spring集成MyBatis​将MyBatis与Spring进行整合，主要解决的问题就是将SqlSessionFactory对象交由Spring来管理。所以，该整合，只需要将SqlSessionFactory的对象生成器SqlSessionFactoryBean注册在Spring容器中，再将其注入给Dao的实现... 查看详情

与spring集成

...iro的组件都是JavaBean/POJO式的组件，所以非常容易使用Spring进行组件管理，可以非常方便的从ini配置迁移到Spring进行管理，且支持JavaSE应用及Web应用的集成。 在示例之前，需要导入shiro-spring及spring-context依赖，... 查看详情

带有spring的PubSub：知​​道消息是不是发布？

】带有spring的PubSub：知​​道消息是不是发布？【英文标题】：PubSubwithspring:knowthemessageispublishornot?带有spring的PubSub：知​​道消息是否发布？【发布时间】：2020-04-0314:29:55【问题描述】：我的发布者代码如下所示：publicabstractcla... 查看详情

activemq与spring集成

声明 转载请注明出处!Reprintpleaseindicatethesource!http://www.hiknowledge.top/2017/04/03/activemq%ef%bc%88%e4%ba%8c%ef%bc%89%e4%b8%8espring%e9%9b%86%e6%88%90/ActiveMQ与Spring集成由于历史原因，JMS有4个版本。Spring提供了用于简化 查看详情

Spring MVC 与 Spring Security 的集成测试

】SpringMVC与SpringSecurity的集成测试【英文标题】：SpringMVCintegrationtestswithSpringSecurity【发布时间】：2013-01-1117:51:46【问题描述】：我正在尝试使用mvc-test测试我的登录页面。在添加spring安全性之前，我的工作非常好。我的代码是：m... 查看详情

GWT 2.4 与 Spring 的集成

】GWT2.4与Spring的集成【英文标题】：GWT2.4IntegrationWithSpring【发布时间】：2011-09-1307:44:26【问题描述】：我目前正在开发GWT2.4/Spring3应用程序，并希望使用RequestFactoryAPI与Spring服务进行通信。从GWT2.4开始，我看到RequestFactoryServlet（Th... 查看详情

ActiveMq 与 Spring 2.5 的集成

】ActiveMq与Spring2.5的集成【英文标题】：ActiveMqintegrationwithSpring2.5【发布时间】：2011-02-2317:15:31【问题描述】：我在Spring2.5.5中使用ActiveMq5.32。我使用非常通用的配置，只要我包含DefaultMessageListenerContainer中的jmsTransactionManager，Sprin... 查看详情

spring-cloud-sleuth 与 spring-amqp 集成

】spring-cloud-sleuth与spring-amqp集成【英文标题】：spring-cloud-sleuthintegrationwithspring-amqp【发布时间】：2016-11-2312:13:17【问题描述】：我只是在使用spring-cloud-sleuth迈出第一步，它适用于各种http调用。现在我正在尝试涵盖消息传递部分... 查看详情

将 JNDI 与 Spring 集成时出错

】将JNDI与Spring集成时出错【英文标题】：ErroruponintegratingJNDIwithSpring【发布时间】：2011-09-2621:28:24【问题描述】：这是我在Spring中第一次尝试使用JNDI，但在尝试创建ApplicationContext时出现以下异常：ApplicationContextcontext=newClassPathXmlA... 查看详情

如何将 Spring 与 JDBC 集成？

】如何将Spring与JDBC集成？【英文标题】：HowtointegrateSpringwithJDBC?【发布时间】：2012-06-0122:47:46【问题描述】：我目前正在使用以下代码连接mysql数据库，但是项目经理说我必须使用Spring框架来处理连接。我怎样才能做到这一点？... 查看详情

Spring session 与 spring security saml 的集成

】Springsession与springsecuritysaml的集成【英文标题】：IntegrationofSpringsessionwithspringsecuritysaml【发布时间】：2016-12-0322:43:30【问题描述】：我想使用openAm对用户进行身份验证并共享会话以与其他微服务进行通信，而无需再次对用户进... 查看详情

Spring-mvc 与 reactjs 的集成？

】Spring-mvc与reactjs的集成？【英文标题】：Spring-mvcintegrationwithreactjs?【发布时间】：2015-06-2308:18:34【问题描述】：我正在尝试将spring-mvc和reactjs集成，但它的示例太差了，但我喜欢reactjs的通量架构师，所以我强烈希望将reactjs与spr... 查看详情

将prometheus与play+spring应用集成

】将prometheus与play+spring应用集成【英文标题】：integratingprometheuswithplay+springapplication【发布时间】：2021-12-0119:33:01【问题描述】：我是prometheus+spring的新手。我的应用程序在play+spring上运行。为了使用千分尺进行监控，我添加了：... 查看详情

spring-cloud-sleuth与spring-amqp集成

我只是用spring-cloud-sleuth做了第一步，它适用于所有类型的http调用。现在我也试着看一下覆盖消息传递部分。我看到spring-cloud-sleuth与开箱即用的spring-integration集成在一起。我目前只使用spring-amqp。还有办法让这个工作。有没有人... 查看详情