如何为活性平http2服务器端口(grpc服务器)？
如何为活性平http2服务器端口(grpc服务器)？
提问于 2017-10-12 06:39:53
我正在尝试平移一个grpc http2服务器端口以获得活性。在Http1.1中，我们将使用url.openConnection并检查响应状态代码。
在http2中，什么是等价的？
下面的代码似乎没有出错，但我不知道如何使用它来检查请求是否成功？
import org.apache.commons.io.IOUtils;
import org.eclipse.jetty.http.HttpFields;
import org.eclipse.jetty.http.HttpURI;
import org.eclipse.jetty.http.HttpVersion;
import org.eclipse.jetty.http.MetaData;
import org.eclipse.jetty.http2.api.Session;
import org.eclipse.jetty.http2.api.Stream;
import org.eclipse.jetty.http2.api.server.ServerSessionListener;
import org.eclipse.jetty.http2.client.HTTP2Client;
import org.eclipse.jetty.http2.frames.DataFrame;
import org.eclipse.jetty.http2.frames.HeadersFrame;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.util.FuturePromise;
import org.eclipse.jetty.util.Jetty;
import org.eclipse.jetty.util.ssl.SslContextFactory;
import javax.net.ssl.HttpsURLConnection;
import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.URL;
import java.util.concurrent.TimeUnit;
public class HeartbeatCheckHttp2 {
public static void main(String [] args) throws Exception {
for (int i=0; i<50000; ++i) {
Thread.sleep(400L);
HTTP2Client client = new HTTP2Client();
client.start();
// Connect to host.
String host = "localhost";
int port = 50000;
FuturePromise<Session> sessionPromise = new FuturePromise<>();
client.connect(new InetSocketAddress(host, port), new ServerSessionListener.Adapter(), sessionPromise);
// Obtain the client Session object.
Session session = sessionPromise.get(5, TimeUnit.SECONDS);
// Prepare the HTTP request headers.
HttpFields requestFields = new HttpFields();
requestFields.put("User-Agent", client.getClass().getName() + "/" + Jetty.VERSION);
requestFields.put("Content-Type", "application/grpc");
// Prepare the HTTP request object.
MetaData.Request request = new MetaData.Request("POST", new HttpURI("http://" + host + ":" + port + "/"), HttpVersion.HTTP_2, requestFields);
// Create the HTTP/2 HEADERS frame representing the HTTP request.
HeadersFrame headersFrame = new HeadersFrame(request, null, true);
// Prepare the listener to receive the HTTP response frames.
Stream.Listener responseListener = new Stream.Listener.Adapter()
{
@Override
public void onData(Stream stream, DataFrame frame, Callback callback)
{
byte[] bytes = new byte[frame.getData().remaining()];
frame.getData().get(bytes);
callback.succeeded();
}
};
session.newStream(headersFrame, new FuturePromise<>(), responseListener);
session.newStream(headersFrame, new FuturePromise<>(), responseListener);
session.newStream(headersFrame, new FuturePromise<>(), responseListener);
Thread.sleep(TimeUnit.SECONDS.toMillis(20));
client.stop();
}
}
}我可以使用SocketAddress来平Tcp的活性，但是我想要进行一个实际的Http2调用来进行活性检查。
回答 1
Stack Overflow用户
回答已采纳
发布于 2017-10-12 08:38:03
HTTP/2协议内置了心跳帧，可以用来“平”另一个节点的活性。
HTTP2Client client = new HTTP2Client();
client.start();
FuturePromise<Session> sessionPromise = new FuturePromise<>();
client.connect(new InetSocketAddress(host, port), new ServerSessionListener.Adapter() {
@Override
public void onPing(Session session, PingFrame frame) {
// The other peer replies to our pings.
}
}, sessionPromise);
Session session = sessionPromise.get(5, TimeUnit.SECONDS);
session.ping(new PingFrame(System.nanoTime(), false), Callback.NOOP);在谈到内置ping工具之后，如果您想检查HTTP请求的响应状态，则应该实现onHeaders()。
Stream.Listener responseListener = new Stream.Listener.Adapter() {
@Override
public void onHeaders(Stream stream, HeadersFrame frame) {
MetaData metaData = frame.getMetaData();
if (metaData.isResponse()) {
MetaData.Response response = (MetaData.Response)metaData;
int status = response.getStatus();
...
}
}
@Override
public void onData(Stream stream, DataFrame frame, Callback callback) {
...
}
};通过HTTP/2帧处理HTTP的服务器就是这样做的。
对于gRPC，情况可能有所不同，因为gRPC协议是通过HTTP/2帧传输的，但不是HTTP。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/46703014
复制相关文章
相似问题
腾讯云开发者
