java - 从不同的 HTTP 请求访问 Spring bean

Question

感谢 Gary Russell 对我之前关于 SO 的问题的回答:Spring Integration manually start/stop channel adapter via control bus，我现在知道如何手动启动和停止 channel 适配器。

我的应用程序现在作为 servlet 在 tomcat 上运行。现在，除了启动该 channel 的请求之外，还有什么办法可以停止该 channel 的请求吗？我不确定范围问题，但在我看来，如果每个请求都在创建一个新网关，因此我从后面的请求发出“停止”命令，只会停止一个新实例，而这从未被停止过首先开始。还是我错了？

我的目标是创建一个 Restful Web 服务，它公开端点以通过 MQTT 发布/订阅/取消订阅，例如

http://someDomain/myModule/publishOverMQTT?topic=cloud&clientID=myClient&payload=myMsg
http://someDomain/myModule/subscribeOverMQTT&URL=someMQTTBrokerURL%clientID=myClient&topics=topic1,topic2,topic3

既然这是作为 servlet 部署的，那么如何实现“取消订阅”请求呢？根据我的理解，取消订阅是在 Spring Integration 中通过停止 channel 来完成的。 !但是!除了启动 channel 的请求之外，是否可以通过请求停止 channel ？

这是我的 context.xml:

<int:control-bus input-channel="controlChannel"/>

<int:gateway
    service-interface="MyGateway"
    default-request-channel="controlChannel"/>

<int-mqtt:message-driven-channel-adapter
    auto-startup="false"
    id="mqttInput" 
    client-id="#{controller.mqttSubscriberConfig.clientID}"
    url="#{controller.mqttSubscriberConfig.completeURL}"
    topics="#{controller.mqttSubscriberConfig.topic}"
    channel="loggingChannel" />

<int:logging-channel-adapter id="loggingChannel" />

按照下面加里·拉塞尔回答中建议的方式实现 HashMap ，我的 Controller 现在看起来像这样:

@RequestMapping("/subscribe")
public @ResponseBody void subscribe(
        @RequestParam(value="topics",   required=true) String topics,
        @RequestParam(value="clientID", required=true) String clientID,
        @RequestParam(value="url",      required=false) String url,
        @RequestParam(value="port",     required=false, defaultValue="1883") Integer port,
        HttpServletRequest request)
{
    mqttSubscriberConfig = new MQTTSubscriberConfiguration();
    mqttSubscriberConfig.setTopic(topics);
    mqttSubscriberConfig.setClientID(clientID);
    mqttSubscriberConfig.setURL(url);
    mqttSubscriberConfig.setPort(port);

    GenericXmlApplicationContext ctx = new GenericXmlApplicationContext();
    ctx.getEnvironment().setActiveProfiles("sub");
    ctx.load("mqtt-context.xml");
    ctx.refresh();

    ((MyGateway)ctx.getBean(MyGateway.class)).control("@mqttInput.start()");

    ctxMap.put(clientID, ctx);
}

@RequestMapping("/unsubscribe")
public @ResponseBody void unsubscribe(
        @RequestParam(value="clientID", required=true) String clientID,
        HttpServletRequest request)
{
    GenericXmlApplicationContext ctx = ctxMap.get(clientID);
    ctx.destroy();
}

仍然，我有一种强烈的感觉，我不应该为每个请求创建上下文。对吗？

Answer 1

Spring Integration bean 没有请求范围；所有请求共享相同的 Spring Integration 基础设施。

不清楚“创建 HTTP 端点以开始/停止订阅”的含义。