我有一个使用Bayeux处理Comet连接的web应用程序。我初始化BayeuxServer并将其绑定到Spring注释中,它可以正常工作,侦听选定的通道并响应。
我有一个Jersey注释类和一个注释Bayeux服务,如下所示。这个想法是我希望能够通过Rest从单个web应用程序控制资源,然后在资源更改后,通过Comet向所有其他适用的客户端执行服务器推送,告诉他们更新他们的信息。
问题是:在部署web应用程序时创建Bayeux服务,设置适当的通道来侦听和监控客户端。这种情况应该只有一次。当Jersey尝试使用Bayeux服务时,它会创建一个全新的服务,而它应该使用原来的服务。这个新服务没有正确注入BayeuxServer,所以我不能通过它访问客户端信息。
它使自从这应该是可行的,但我似乎不明白如何注入这些东西正确通过注释。有人能给我指个方向吗?
Jersey注释类:
@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();
}
}
BayeuxService:
@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...");
}
}
参见Jersey和spring集成- bean注入在运行时为空。
我又问了一个问题。这两个问题都源于同样的问题,包括正确设置Jersey依赖并将其与spring集成。