Bayeuxを使用してComet接続を処理しているWebアプリがあります。BayeuxServerを初期化し、それをSpringアノテーションに結び付けます。すべて正常に機能し、選択したチャネルでリッスンして応答します。
以下に示すように、ジャージーの注釈付きクラスと注釈付きのバイユーサービスがあります。アイデアは、個々のWebアプリからRestを介してリソースを制御できるようにし、リソースが変更された直後に、Cometを介して他のすべての該当するクライアントにサーバープッシュを実行して、情報を更新するように指示することです。
問題は次のとおりです。Webアプリがデプロイされるとバイユーサービスが作成され、クライアントをリッスンして監視するための適切なチャネルが設定されます。これのインスタンスは1つだけである必要があります。ジャージーがバイユーサービスを使おうとすると、元のサービスを使用する必要があるときに、まったく新しいサービスが作成されます。この新しいサービスには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();
}
}
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...");
}
}