@Override
public void onOpen(Session session, EndpointConfig config) {
String id = session.getId();
log.debug("{}: open ws proxy ", id);
try {
ChannelFuture cf = backend.connect().sync();
Channel channel = cf.channel();
WebSocketClientProtocolHandler wscph = makeWsProtocolHandler(session);
WebSocketClientHandshaker handshaker = wscph.handshaker();
WsHandler handler = new WsHandler(handshaker, channel, session);
channel.pipeline().addLast(new HttpObjectAggregator(1024 * 4),
WebSocketClientCompressionHandler.INSTANCE,
wscph,
handler);
handshaker.handshake(channel);
log.debug("{}: wait messages", id);
session.addMessageHandler(String.class, handler::onFrontString);
session.addMessageHandler(ByteBuffer.class, handler::onFrontBytes);
} catch (Exception e) {
log.error("{}: can not establish ws connect with backed", id, e);
}
}
WsProxy.java 文件源码
java
阅读 32
收藏 0
点赞 0
评论 0
项目:haven-platform
作者:
评论列表
文章目录