circlecloud/ms
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix: some bug

Browse Source 
Signed-off-by: MiaoWoo <admin@yumc.pw>
This commit is contained in:
MiaoWoo
2022-07-06 21:57:36 +08:00
parent b6d7847a79
commit d8d03149df
5 changed files with 29 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
packages/websocket/src/client/netty/index.ts
View File

@ -58,7 +58,7 @@ export class NettyWebSocket extends Transport {
private _host: string
private _port: number
private channel: any
private b = new Bootstrap();
private b: any
constructor(url: string, subProtocol: string = '', headers: WebSocketHeader = {}) {
super(url, subProtocol, headers)
@ -102,6 +102,7 @@ export class NettyWebSocket extends Transport {
// HttpResponseDecoder to WebSocketHttpResponseDecoder in the pipeline.
let handler = new WebSocketClientHandler(WebSocketClientHandshakerFactory
.newHandshaker(uri, WebSocketVersion.V13, null, false, headers), this)
this.b = new Bootstrap()
this.b.group(group)
.channel(socketChannelClass)
.handler(new ChannelInitializer({
@ -123,18 +124,22 @@ export class NettyWebSocket extends Transport {
}
}))
this.b.connect(this._host, this._port).addListener(new ChannelFutureListener((future: any) => {
this.channel = future.sync().channel()
this.onconnection({})
handler.handshakeFuture.addListener(new ChannelFutureListener((future: any) => {
try {
future.sync()
// only trigger onconnect when not have error
this.onconnect({})
} catch (error: any) {
// ignore error exceptionCaught from handler
// this.onerror({ error })
}
}))
try {
this.channel = future.sync().channel()
this.onconnection({})
handler.handshakeFuture.addListener(new ChannelFutureListener((future: any) => {
try {
future.sync()
// only trigger onconnect when not have error
this.onconnect({})
} catch (error: any) {
// ignore error exceptionCaught from handler
// this.onerror({ error })
}
}))
} catch (error: any) {
this.onerror({ error })
}
}))
}
doSend(text: string) {