6

我在我的 Spring MVC 应用程序中使用 Atmosphere 来促进推送，使用streaming传输。

在我的应用程序的整个生命周期中，客户端将订阅和取消订阅许多不同的主题。

Atmosphere 似乎对每个订阅使用一个 http 连接 - 即，每次调用$.atmosphere.subscribe(request)都会创建一个新连接。这很快耗尽了允许从浏览器到大气服务器的连接数。

我不想每次都创建新资源，而是希望能够在AtmosphereResource初始创建后向广播公司添加和删除。

但是，由于AtmosphereResource是入站请求的一对一表示，每次客户端向服务器发送请求时，它都会到达一个新的AtomsphereResource，这意味着我无法引用原始资源，并将其附加到话题的Broadcaster。

我已经尝试使用两者$.atmosphere.subscribe(request)并调用atmosphereResource.push(request)从原始subscribe()调用返回的资源。然而，这并没有什么不同。

解决这个问题的正确方法是什么？

4

1 回答 1

9

这是我如何让它工作的：

首先，当客户端进行初始连接时，请确保在调用之前浏览器接受特定于大气的标头suspend()：

@RequestMapping("/subscribe")
public ResponseEntity<HttpStatus> connect(AtmosphereResource resource)
{
    resource.getResponse().setHeader("Access-Control-Expose-Headers", ATMOSPHERE_TRACKING_ID + "," + X_CACHE_DATE);
    resource.suspend();
}

然后，当客户端发送额外的订阅请求时，尽管它们来自不同的resource，但它们包含ATMOPSHERE_TRACKING_ID原始资源的 。这允许您通过以下方式查找它resourceFactory：

@RequestMapping(value="/subscribe", method=RequestMethod.POST)
public ResponseEntity<HttpStatus> addSubscription(AtmosphereResource resource, @RequestParam("topic") String topic)
{
    String atmosphereId = resource.getResponse().getHeader(ATMOSPHERE_TRACKING_ID);
    if (atmosphereId == null || atmosphereId.isEmpty())
    {
        log.error("Cannot add subscription, as the atmosphere tracking ID was not found");
        return new ResponseEntity<HttpStatus>(HttpStatus.BAD_REQUEST);
    }
    AtmosphereResource originalResource = resourceFactory.find(atmosphereId);
    if (originalResource == null)
    {
        log.error("The provided Atmosphere tracking ID is not associated to a known resource");
        return new ResponseEntity<HttpStatus>(HttpStatus.BAD_REQUEST);
    }

    Broadcaster broadcaster = broadcasterFactory.lookup(topic, true);
    broadcaster.addAtmosphereResource(originalResource);
    log.info("Added subscription to {} for atmosphere resource {}",topic, atmosphereId);

    return getOkResponse();
}
于 2012-12-13T19:55:21.183 回答