我正在尝试了解 Bayeux 协议。我还没有找到详细解释bayeux 客户端在技术上如何工作的网络资源。
从这个资源，
Bayeux 协议要求新客户端发送的第一条消息是握手消息（在 /meta/handshake 通道上发送的消息）。
客户端处理握手回复，如果成功，则在后台启动与服务器的心跳机制，通过交换连接消息（在 /meta/connect 通道上发送的消息）。
这种心跳机制的细节取决于使用的客户端传输，但可以看作是客户端发送连接消息并在一段时间后等待回复。
连接消息继续在客户端和服务器之间流动，直到任何一方决定通过发送断开连接消息（在 /meta/disconnect 通道上发送的消息）来断开连接。
我已经用 Java 方法编写了首先进行握手，然后订阅特定频道的方法。我利用 Apache HttpClient 库来执行 HTTP POST 请求。
现在是连接部分。
我的理解是，我需要保持对bayeux服务器的请求，并且每当我收到响应时，都会发出另一个请求。
我已经写了下面的代码。我的理解是否正确，这个bayeux客户端是否表现出正确的连接功能？（请忽略缺少的断开连接，取消订阅方法）
此外，我已经针对bayeux 服务器测试了代码并且它可以正常工作。
/* clientId - Unique clientId returned by bayeux server during handshake
responseHandler - see interface below */
private static void connect(String clientId, ResponseHandler responseHandler)
throws ClientProtocolException, UnsupportedEncodingException, IOException {
String message = "[{\"channel\":\"/meta/connect\","
+ "\"clientId\":\"" + clientId + "\"}]";
CloseableHttpClient httpClient = HttpClients.createDefault();
Thread t = new Thread(new Runnable() {
@Override
public void run() {
while (!doDisconnect) {
try {
CloseableHttpResponse response = HttpPostHelper.postToURL(ConfigurationMock.urlRealTime,
message, httpClient, ConfigurationMock.getAuthorizationHeader());
responseHandler.handleResponse(response);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
try {
httpClient.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
t.start();
}
/*Simple interface to define what happens with the response when it arrives*/
private interface ResponseHandler {
void handleResponse(CloseableHttpResponse httpResponse);
}
public static void main(String[] args) throws Exception{
String globalClientId = doHandShake(); //assume this method exists
subscribe(globalClientId,"/measurements/10500"); //assume this method exists
connect(globalClientId, new ResponseHandler() {
@Override
public void handleResponse(CloseableHttpResponse httpResponse) {
try {
System.out.println(HttpPostHelper.toStringResponse(httpResponse));
} catch (ParseException | IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
}