0

我有一个使用 Bayeux 处理 Comet 连接的网络应用程序。我初始化了一个 BayeuxServer 并将其绑定到 Spring 注释中，一切正常，监听选定的通道并做出响应。

我有一个 Jersey 注释类和一个带注释的 Bayeux 服务，如下所示。我的想法是我希望能够通过单个 Web 应用程序的 Rest 控制资源，然后在资源更改后立即通过 Comet 向所有其他适用的客户端推送服务器，告诉他们更新信息。

问题是：部署 webapp 时会创建 Bayeux 服务，设置适当的通道来监听和监控客户端。这种情况应该只有一个。当 Jersey 尝试使用 Bayeux 服务时，它会创建一个全新的服务，而它应该使用原来的服务。这项新服务没有正确注入 BayeuxServer，因此我无法通过它访问客户端信息。

因为这应该是可行的，但我似乎不明白如何通过注释正确注入这些东西。谁能指出我正确的方向？

泽西注释类：

@Path("JsonTest")
public class JsonTest {

@Context
Request request;
@Context
UriInfo uriInfo;

@Context
ResourceContext resourceContext;

protected final Logger log = Logger.getLogger(getClass());

public JsonTest() {

}

@DELETE
@Path("{id}")
public void deleteJson(@PathParam("id") String id) {
    JsonTestDao.instance.getModel().remove(id);
    log.info("Deleted Json..." + id);
    log.info("New json: " + JsonTestDao.instance.getModel().toString());


    JsonTestService jsonTestService = resourceContext.getResource(JsonTestService.class);
    jsonTestService.sendUpdate();
}
}

Bayeux服务：

@Named
// Singleton here didn't seem to make a difference
@Service
public class JsonTestService {

protected final Logger log = Logger.getLogger(getClass());

@Inject
private BayeuxServer bayeux;
@Session
private ServerSession serverSession;

@PostConstruct
public void init() {
    log.info("Initializing JsonTest Bayeux HelloService...");
    log.info("Current sessions are: " + bayeux.getSessions().toString());
}

@Listener("/cometd/JsonTest")
public void jsonTestHandler(ServerSession remote, ServerMessage.Mutable message) {

}

public void sendUpdate() {
    //bayeux.newMessage(); // Need a method that the Jersey class can call to notify changes
    log.info("Bayeux server should be sending an update now...");
}

@PreDestroy
public void destroy() {
    log.info("Destroying JsonTest Bayeux HelloService...");
}

}
4

1 回答 1

0

请参阅Jersey 和 spring 集成 - bean Injections 在运行时为空。

我问的另一个问题。这两者都源于同一个问题，涉及正确设置 Jersey 依赖项并将其与 spring 集成。

于 2011-07-13T06:03:42.317 回答