正文 

当前位置： 首页 > 源码 >

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

     2023-02-16     94

关键词：

【中文标题】Spring boot：将消息推送到每个请求的特定主题【英文标题】：Spring boot: push message to specific topic for each request 【发布时间】：2020-04-01 23:55:02 【问题描述】：

我正在使用 pub sub 与 spring boot 的集成，我的配置类如下所示：

@Configuration
public class PubSubConfiguration 

    @Value("$spring.pubsub.topic.name")
    private String topicName;

    @Bean
    @ServiceActivator(inputChannel = "MyOutputChannel")
    public PubSubMessageHandler messageSender(PubSubTemplate pubsubTemplate) 
        return new PubSubMessageHandler(pubsubTemplate, topicName);
    

    @MessagingGateway(defaultRequestChannel = "MyOutputChannel")
    public interface PubsubOutboundGateway 
        void sendToPubsub(String attribute);

所以现在，我只调用了 sendToPubSub 方法，该方法将有效负载从我的应用程序添加到主题中，如下所示：

@Autowired
private PubSubConfiguration.PubsubOutboundGateway outboundGateway;

// used line in my code wherever is needed. 
outboundGateway.sendToPubsub(jsonInString);

以上代码仅适用于我从应用程序属性文件加载的一个主题。

但是现在我想让我的主题名称动态添加到messageSender中，该怎么做。

【问题讨论】：

【参考方案1】：

考虑创建一个BeanFactory 来生成一个给定主题名称的 PubSubMessageHandler Bean。 PubSubMessageHandler 还有一个 setTopic() 方法，可能有用。

【讨论】：

Spring Boot 执行器保持状态

】SpringBoot执行器保持状态【英文标题】：SpringBootActuatorMaintainState【发布时间】：2021-12-2803:42:55【问题描述】：我正在使用千分尺将自定义指标推送到Prometheus。因此，prometheus抓取/actuator/prometheus并存储数据。但问题是，当我重新... 查看详情

将消息推送到谷歌云发布订阅后如何返回对 webflux 端点的响应？

...【发布时间】：2020-08-1618:07:02【问题描述】：我正在使用Spring集成创建一个简单的SpringBoot应用程序。下面是这个应用程序的三个主要结构：入站网关：接受http请求的WebFl 查看详情

CUBA 平台将消息从后端推送到 UI

】CUBA平台将消息从后端推送到UI【英文标题】：CUBAPlatformpushmessagesfrombackendtoUI【发布时间】：2020-11-1611:02:01【问题描述】：我想知道是否可以从后端（例如，从外部系统接收信息的正在运行的任务）向UI发送消息。在我的情况下... 查看详情

是否可以将消息推送到使用应用程序 ID 注册的所有设备？

】是否可以将消息推送到使用应用程序ID注册的所有设备？【英文标题】：IsthatpossibletopushmessagetoallthedevicesregisteredwithaApplicationID?【发布时间】：2013-12-0406:54:38【问题描述】：我需要使用PHP代码将消息推送到GCM服务器，该代码在... 查看详情

如何在没有安装 MQTT 应用程序的设备的情况下在 android 上使用 MQTT 将消息推送到特定 IP？

...没有安装MQTT应用程序的设备的情况下在android上使用MQTT将消息推送到特定IP？【英文标题】：HowtouseMQTTonandroidtopushmessagestoaspecificIPwithoutthedevicehavingtheMQTTappinstalled?【发布时间】：2017-07-2916:57:36【问题描述】：我在JavaAndroidStudio中... 查看详情

将消息从 HTTP 端点推送到 Mule 中的 JMS 端点

】将消息从HTTP端点推送到Mule中的JMS端点【英文标题】：PushmessagefromHTTPendpointtoJMSendpointinMule【发布时间】：2016-03-0208:40:37【问题描述】：我是MuleESB的新手。目前我正在处理一个项目，我们使用Mule作为消息代理。要求是客户端将... 查看详情

Spring SAML：如何将请求的 URL 作为 RELAY_STATE 推送到 SAML？

】SpringSAML：如何将请求的URL作为RELAY_STATE推送到SAML？【英文标题】：SpringSAML:howtopushtherequestedURLtoSAMLasRELAY_STATE?【发布时间】：2017-02-1123:31:19【问题描述】：例如，您的网站上有两个不同的文件夹，/folderA和/folderB您可以在SpringSec... 查看详情

Spring Cloud Sleuth 在 spring-boot/spring cloud 升级后停止将 X-B3-TraceId 推送到 MDC

】SpringCloudSleuth在spring-boot/springcloud升级后停止将X-B3-TraceId推送到MDC【英文标题】：SpringCloudSleuthstoppedpushingX-B3-TraceIdintoMDCafterspring-boot/springcloudupgrade【发布时间】：2021-07-2802:29:44【问题描述】：我已将Springboot依赖项从2.1升级到2.4... 查看详情

在推送到 Codecommit 时需要特定的提交消息 AWS Lambda

】在推送到Codecommit时需要特定的提交消息AWSLambda【英文标题】：RequireSpecificCommitMessageAWSLambdaonPushtoCodecommit【发布时间】：2020-03-2808:59:27【问题描述】：我正在尝试强制执行以“BPSD-XXXXX”开头的提交，并且无法弄清楚如何在推送... 查看详情

为啥当我尝试将我的 Spring Boot 应用程序推送到 heroku 时它返回“致命错误编译：无效目标版本：11”

】为啥当我尝试将我的SpringBoot应用程序推送到heroku时它返回“致命错误编译：无效目标版本：11”【英文标题】：WhywhenitrypushmySpringbootapptoherokuitreturn"Fatalerrorcompiling:invalidtargetrelease:11"为什么当我尝试将我的SpringBoot应用程... 查看详情

如何将状态推送到包含特定项目的数组？

】如何将状态推送到包含特定项目的数组？【英文标题】：HowcanIpushthestatetoanarraywithspecificitems?【发布时间】：2020-04-1007:57:48【问题描述】：我的大部分项目都处于我想将其推送到数组中的状态我想将所有状态推送到某些项目之... 查看详情

将更改推送到特定分支时不会触发多分支管道

...置Webhook。在存储库级别设置了Webhook之后，如果将更改推送到其下的任何分支，则应触发该分支的构建。这可能吗？答案您是否测试过GitH 查看详情

Spring Webflux：将服务器发送事件推送给特定用户

】SpringWebflux：将服务器发送事件推送给特定用户【英文标题】：SpringWebflex:PushServerSentEventtoSpecificUsers【发布时间】：2020-07-2504:33:09【问题描述】：我一直关注this以供参考。我正在开发一个具有经过身份验证的用户的spring-boot应... 查看详情

如何将特定提交推送到远程，而不是以前的提交？

】如何将特定提交推送到远程，而不是以前的提交？【英文标题】：HowcanIpushaspecificcommittoaremote,andnotpreviouscommits?【发布时间】：2011-03-1421:23:05【问题描述】：我已经对不同的文件进行了多次提交，但到目前为止，我只想将特定... 查看详情

Gcp PubSub 未将消息推送到 REST 端点

】GcpPubSub未将消息推送到REST端点【英文标题】：GcpPubSubnotpushingmessagetoRESTEndpoint【发布时间】：2017-07-1717:38:32【问题描述】：我遇到了一个问题，GcpPubSub没有将消息推送到我注册的端点。让我详细叙述一下我执行的步骤。注意，... 查看详情

如何将数据推送到jsp而不每2秒请求一次？

...秒将数据推送到jsp，而不需要客户端请求。我在这里使用Spring和Hibernate。我正在显示谷歌地图标记，我想通过从数据库中获取数据每2秒更新一次标记位置，但是我已经完成了每2秒从数据 查看详情

Android，将消息快速推送到 1000 台设备

】Android，将消息快速推送到1000台设备【英文标题】：Android,pushmessagesto1000devicesfast【发布时间】：2012-01-0914:08:26【问题描述】：我已经实现了c2dm，并且设备可以正常接收消息和所有内容。但是有一个问题我找不到解决方案。当... 查看详情

Swift Parse：如何将通知推送到特定的设备/objectId

】SwiftParse：如何将通知推送到特定的设备/objectId【英文标题】：SwiftParse:HowtoPushNotificationToaSpecificDevice/objectId【发布时间】：2015-05-0621:39:24【问题描述】：我正在尝试向我的用户表中的特定用户推送通知，但我的功能不起作用，... 查看详情