在grpc java/node上处理客户端和服务器错误

我正在使用grpc在Java服务器和节点客户端之间进行通信。当他们中的任何一方死亡时，另一方死亡。在grpc java/node上处理客户端和服务器错误

这里是抛出的Java服务器上的异常，当节点的客户端死机 -

Nov 08, 2016 11:28:03 AM io.grpc.netty.NettyServerHandler onConnectionError 
WARNING: Connection Error 
java.io.IOException: An existing connection was forcibly closed by the remote host 
    at sun.nio.ch.SocketDispatcher.read0(Native Method) 
    at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43) 
    at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) 
    at sun.nio.ch.IOUtil.read(IOUtil.java:192) 
    at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) 
    at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288) 
    at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1100) 
    at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:349) 
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:112) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:571) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:512) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:426) 
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:398) 
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:877) 
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) 
    at java.lang.Thread.run(Thread.java:745)

这里是扔在节点异常时，Java的死亡：

events.js:141 
     throw er; // Unhandled 'error' event 
    ^
Error: {"created":"@1478623914.082000000","description":"An existing connection was forcibly closed by the remote  host.\r\n","file":"..\src\core\lib\iomgr\tcp_windows.c","file_line":171,"grpc_status":14}  
    at ClientReadableStream._emitStatusIfDone ( C:\HarshalDev\Live_TDFX\TDSL0007-TDFXPlatfo rmsDesignandBuild\tdfxlive\node_modules\grpc\src\node\src\client.js:189:19) 
    at ClientReadableStream._receiveStatus (C:\ HarshalDev\Live_TDFX\TDSL0007-TDFXPlatformsDesignandBuild\tdfxlive\node_modules\grpc\src\node\src\client.js:169:8) 
    at C:\HarshalDev\Live_TDFX\TDSL0007-TDFXPlatformsDesignandBuild\tdfxlive\node_modules\grpc\src\node\src\client.js:577:14 
[nodemon] app crashed - waiting for file changes before starting...

的问题 - 如何处理这些异常？

我尝试没有任何成功添加try/catch并为线程添加未捕获的异常处理程序。

Java代码来初始化 -

ServerBuilder<?> serverBuilder = ServerBuilder.forPort(getPort()); 
server = serverBuilder 
     .addService(createBwayStreamingService()) 
     .addService(ServerInterceptors.intercept(createBwayOrderService(), authServerInterceptor)) 
     .addService(createBwayInstrumentService()) 
     .addService(createBwaySettlementService()) 
     .addService(createBwayDateTimeService()) 
     .addService(ServerInterceptors.intercept(createBwayConfService(), authServerInterceptor)) 
     .addService(ServerInterceptors.intercept(createBwayTradeService(), authServerInterceptor)) 
     .addService(ServerInterceptors.intercept(createBwayAuthService(), authServerInterceptor)) 
     .build(); 
Preconditions.checkNotNull(server); 
server.start(); 
System.out.println("Server started, listening on " + getPort()); 
Runtime.getRuntime().addShutdownHook(new Thread() { 
    @Override 
    public void run() { 
     System.out.println("Shutting down gRPC server"); 
     TocGateway.this.stop(); 
     System.out.println("Server shut down"); 
    } 
}); 
server.awaitTermination();

节点客户端处理程序（的服务之一，所有其他服务都使用相同的模式） -

let protoDescriptorStreaming = grpc.load((process.env.FX_LIVE_PROTO_DIR || '../tocGateway/src/main/proto') + '/streaming.proto'); 
let streamingService = new protoDescriptorStreaming.tds.fxlive.bway.BwayStreamService(process.env.TOC_GATEWAY_ADDRESS || 'localhost:8087', grpc.credentials.createInsecure());

来源

2016-11-08 user2643769

Java的警告是无害的。发生异常后，应用程序应继续正常运行。将日志级别降低到减少logspam会很好，但它也不应该影响应用程序的正确性。

来源

2016-11-09 00:33:26

在Node方面，我和OP一样苦恼，但答案是我没有处理错误事件。修复后，我的Node应用程序将在错误发生后继续运行。 –

如果您在学习grpc时遇到此问题，那是因为您没有优雅地终止客户端 - .channel.shutdown.awaitTermination（5，TimeUnit.SECONDS）请参阅http://comments.gmane.org/gmane.comp.lib。 GRPC/2474 –

在grpc java/node上处理客户端和服务器错误

回答

相关问题