Q&A
「roomのrun()をgoroutineで動かし...」とありますが、この表現は「runを複数のgoroutineで動かす」という意味にも取れます。実際はどうなのでしょう？
現在Goを勉強中で，Go＋WebSocketを用いて
大人数によるリアルタイムチャットを実装しようとしています．
https://github.com/oreilly-japan/go-programming-blueprints/tree/master/chapter1/chat
を参考に，
「roomのrun()をgoroutineで動かし，そのroom内でWebSocketで接続するuserを管理する」
と言うようなほぼ同じ実装を行っており，
順調にリアルタイムチャットが動作していることが確認できましたが，
一定上のuser数を超えると，挙動がすこし変わってきました．
観測できた現象としては，
roomを動かしているgoroutineは１つ，
つまり，チャット部屋は１つしかない，と思っていましたが
かなりのユーザを参加させると，ユーザによって参加(接続)しているチャット部屋が違うように観測できました．
たとえば，ユーザが２００人参加(接続)しているとして，
１５０人は部屋A，50人は部屋Bに接続されているように見えました．
ここから考えられた仮説として，
外部からは１つの部屋(goroutine)に見えるが，Goが内部的にgoroutineの複製を行って処理を分散させる．
しかし，WebSocketがコネクションを張り続ける性質上，内部的に複製されたgoroutineの１つに接続しつづけるので，
ユーザによって外部から入る部屋(goroutine)は同じように見えても，実際に参加(接続)した内部的な部屋は異なるので，
挙動が異なるのではないか，と考えられました．
ステートレスなgoroutineであれば，Goが内部的に処理を分散させるのは理にかなっていますが，
長期的なコネクションを持つという，今回のパターンではそれが裏目に出た結果，
このような挙動になったのではないかと思いました．
私の知識不足なことがあるのでしょうが，Goの仕様として
WebSocketの接続数や何らかの負荷が原因で
全く同じgoroutineが「勝手に」複製される，
というようなことはあるのでしょうか？
また，それがあるとすれば
その複製をさせずに，全ユーザを同じroomに参加させるにはどうすればいいでしょうか？
よろしくお願いいたします．
参考URL先のmain.go内のmainの中で呼ばれるように，「go r.run()」と１回呼び出す形です．これで，１つのチャット部屋ができていてそこにユーザが出入りする，という流れになると思っていました．GOMAXPROCSが関係あるのか，と考えていますが，確証はありません．
参考までに伺いたいのですが、オリジナルのソースで本件のような現象が発生するか確認されているでしょうか？質問者さんの推測が正しいとするとオリジナルサーバーでも同様のことが発生する気がするので。
オリジナルのソースでの検証は行っていません．チャット部屋の作成やユーザの入退出といった部分は同じですので，オリジナルサーバでも同様のことが発生すると思いますが，なにぶんブラックボックス化されている部分だと思いますのでこの挙動を安定して再現する方法もわかりません．
質問者さんの推測通りとすると(確信はないですが)goのバグのように思えてきます。なお自分はWin10でhttps://github.com/golang/goからinstallしたものを使ってますが、NumCPU,GOMAXPROCSともに4(2coreのPCです)でした。もしご質問の現象の再現性があるならGOMAXPROCSを1に制限して再現するか確認してみると閲覧者にとっても参考になる気がします。
ソールが無いので断言は出来ませんが、ukai さんのサンプルは部屋が1つでクッキー等も使っていないので現在ブラウザが開いている部屋がどちらなのかを判定するコードもありません。おそらくですが、その現象が発生したユーザはA/B両方の端末に接続されたのではないでしょうか？同じ websocket を A/B 双方にリクエストしてしまい、それぞれの map に同じコネクションが含まれてしまったのでは？という推測は出来ます。
回答1件
0
ベストアンサー
全く同じgoroutineが「勝手に」複製されるということはありえません。
例えばプロセスを止めきらずにもう一つプロセスを起動できたりすると
分断した部屋が存在する可能性があるかもしれません。
投稿2017/12/15 12:42
総合スコア3367
あなたの回答
tips
プレビュー
