comet 重启后ch.CliProto.Set()获取数据一致阻塞导致HandshakeTimeout，这个如何解决

[manyhappy163]

E0822 13:38:14.057201 46837 client.go:551] discovery: client.Get(http://127.0.0.1:7171/discovery/polls?appid=infra.discovery&env=dev&hostname=mymac&latest_timestamp=1566449420450314000) error(Get http://127.0.0.1:7171/discovery/polls?appid=infra.discovery&env=dev&hostname=mymac&latest_timestamp=1566449420450314000: context canceled) E0822 13:38:26.553473 46837 server_websocket.go:185] the step: 1 E0822 13:38:26.553569 46837 server_websocket.go:199] the step: 2 E0822 13:38:26.553686 46837 server.go:51] the response challengeKey=iz5JCnLhHRPukYzmSaYSGw== : theSec-WebSocket-Accept = %!(EXTRA string=rxOKx+GqvK6ti7hHdVynZJWU/MM=) E0822 13:38:26.553714 46837 server_websocket.go:213] the step: 3 E0822 13:38:56.555451 46837 server_websocket.go:179] key: remoteIP: 192.168.0.120:58692 step: 3 ws handshake timeout E0822 13:39:27.499929 46837 server_websocket.go:185] the step: 1 E0822 13:39:27.500004 46837 server_websocket.go:199] the step: 2 E0822 13:39:27.500078 46837 server.go:51] the response challengeKey=VDAz/NS8tePBR7+nz9WljA== : theSec-WebSocket-Accept = %!(EXTRA string=kSrLc/fKwgrwv6xNXpg/FbXNqlI=) E0822 13:39:27.500105 46837 server_websocket.go:213] the step: 3 E0822 13:39:57.503124 46837 server_websocket.go:179] key: remoteIP: 192.168.0.120:58788 step: 3 ws handshake timeout E0822 13:40:44.072768 46837 server_websocket.go:225] the step: 4 E0822 13:40:44.072808 46837 server_websocket.go:225] the step: 4 E0822 13:40:44.072809 46837 server_websocket.go:227] get the proto from the channel error:write tcp 192.168.0.137:3102->192.168.0.120:58692: use of closed network connection E0822 13:40:44.072871 46837 server_websocket.go:227] get the proto from the channel error:write tcp 192.168.0.137:3102->192.168.0.120:58788: use of closed network connection E0822 13:40:44.072894 46837 server_websocket.go:233] key: e93cbaeb-5ff0-468f-9ddf-55fbd89de994 remoteIP: 192.168.0.120:58692 step: 4 ws handshake failed error(write tcp 192.168.0.137:3102->192.168.0.120:58692: use of closed network connection) E0822 13:40:44.072906 46837 server_websocket.go:233] key: 387145ed-0066-4f89-99ea-32da13fb8b68 remoteIP: 192.168.0.120:58788 step: 4 ws handshake failed error(write tcp 192.168.0.137:3102->192.168.0.120:58788: use of closed network connection) E0822 13:40:58.448680 46837 server_websocket.go:185] the step: 1 E0822 13:40:58.449234 46837 server_websocket.go:199] the step: 2 E0822 13:40:58.449325 46837 server.go:51] the response challengeKey=BQyJNSplCzI6m0sBFVutUw== : theSec-WebSocket-Accept = %!(EXTRA string=7vN4XO201oIhyfIL126Rw2uVH5c=) E0822 13:40:58.449344 46837 server_websocket.go:213] the step: 3 E0822 13:40:58.455288 46837 server_websocket.go:225] the step: 4

[ALEX-yinhao]

我也有这个问题，请问解决了么。。。

[lishuhao]

我也是同时重启comet、job、logic三个服务，就会出现这个问题

true
I0117 12:25:27.328130   70511 main.go:40] goim-comet [version: 2.0.0 env: &{Region:sh Zone:sh001 DeployEnv:dev Host:shuhaoDeMBP.local Weight:10 Offline:false Addrs:[127.0.0.1]}] start
I0117 12:25:27.330718   70511 client.go:213] disocvery: AddWatch(infra.discovery) already watch(false)
I0117 12:25:27.337711   70511 client.go:569] discovery: successfully polls(http://127.0.0.1:7171/discovery/polls?appid=infra.discovery&env=dev&hostname=shuhaoDeMBP.local&latest_timestamp=0) instances ({"infra.discovery":{"instances":{"sh001":[{"region":"sh","zone":"sh001","env":"dev","appid":"infra.discovery","hostname":"test1","addrs":["http://127.0.0.1:7171"],"version":"","latest_timestamp":1579088063451830000,"metadata":null}]},"latest_timestamp":1579088063451830000,"scheduler":null}})
I0117 12:25:27.373760   70511 client.go:213] disocvery: AddWatch(goim.logic) already watch(false)
E0117 12:25:27.373852   70511 client.go:551] discovery: client.Get(http://127.0.0.1:7171/discovery/polls?appid=infra.discovery&env=dev&hostname=shuhaoDeMBP.local&latest_timestamp=1579088063451830000) error(Get http://127.0.0.1:7171/discovery/polls?appid=infra.discovery&env=dev&hostname=shuhaoDeMBP.local&latest_timestamp=1579088063451830000: context canceled)
I0117 12:25:27.381089   70511 server_tcp.go:38] start tcp listen: :3101
I0117 12:25:27.381244   70511 server_websocket.go:35] start ws listen: :3102
I0117 12:25:27.382468   70511 client.go:353] discovery: register client.Get(http://127.0.0.1:7171/discovery/register) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:25:27.383187   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:25:37.387415   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:25:47.392167   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:25:57.568031   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:26:07.569088   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:26:17.574237   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:26:27.599549   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:26:37.603418   70511 client.go:458] discovery: set client.Get(http://127.0.0.1:7171/discovery/set?appid=goim.comet&env=dev&hostname=shuhaoDeMBP.local&metadata=%7B%22addrs%22%3A%22127.0.0.1%22%2C%22conn_count%22%3A%220%22%2C%22ip_count%22%3A%220%22%2C%22offline%22%3A%22false%22%2C%22weight%22%3A%2210%22%7D&region=sh&status=1&version=&zone=sh001) env(dev) appid(goim.comet) addrs([grpc://10.0.4.136:3109]) success
I0117 12:26:37.610646   70511 server_tcp.go:92] start tcp serve "10.0.4.136:3101" with "10.0.4.136:61428"
I0117 12:26:37.610722   70511 server_tcp.go:115] receive socket msg --------
I0117 12:26:37.610790   70511 server_tcp.go:130] start auth  1579235197
I0117 12:26:37.783931   70511 server_tcp.go:358] auth body({"mid":1004,"key":"shuhao","room_id":"","platform":"web","accepts":[2001,2002,2003,2004,2005,10001,10002,10003,10004,10005,10006,10007,10008,10009,10010,10011,10012,10013,10014,10015]}),proto(ver:1 op:7 seq:1 body:"{\"mid\":1004,\"key\":\"shuhao\",\"room_id\":\"\",\"platform\":\"web\",\"accepts\":[2001,2002,2003,2004,2005,10001,10002,10003,10004,10005,10006,10007,10008,10009,10010,10011,10012,10013,10014,10015]}" )
I0117 12:26:44.156675   70511 server_tcp.go:92] start tcp serve "10.0.4.136:3101" with "10.0.4.136:61436"
I0117 12:26:44.156730   70511 server_tcp.go:115] receive socket msg --------
I0117 12:26:44.156760   70511 server_tcp.go:130] start auth  1579235204
I0117 12:26:44.319981   70511 server_tcp.go:358] auth body({"mid":1004,"key":"shuhao","room_id":"","platform":"web","accepts":[2001,2002,2003,2004,2005,10001,10002,10003,10004,10005,10006,10007,10008,10009,10010,10011,10012,10013,10014,10015]}),proto(ver:1 op:7 seq:1 body:"{\"mid\":1004,\"key\":\"shuhao\",\"room_id\":\"\",\"platform\":\"web\",\"accepts\":[2001,2002,2003,2004,2005,10001,10002,10003,10004,10005,10006,10007,10008,10009,10010,10011,10012,10013,10014,10015]}" )
E0117 12:26:45.610893   70511 server_tcp.go:124] key:  remoteIP: 10.0.4.136:61428 step: 1 tcp handshake timeout