個人用のローカル接続のみで使うメッセージ系のプログラムをwxpythonで操作しようと考えているのですが、serverを建てたり、client接続する際に動作が停止するという問題にぶつかっています。
以下コードです。
python
1import wx 2import zmq 3 4#メッセージ交換に使用する関数 5def server_bind(port): 6 context = zmq.Context() 7 server = context.socket(zmq.REP) 8 server.bind("tcp://127.0.0.1:" + str(port)) 9 return server 10 11def client_connect(port): 12 context = zmq.Context() 13 client = context.socket(zmq.REQ) 14 client.connect("tcp://127.0.0.1:" + str(port)) 15 return client 16 17def server_recv(server, y): 18 x = server.recv_pyobj() 19 server.send_pyobj(y) 20 return x 21 22def client_recv(client, y): 23 client.send_pyobj(y) 24 return client.recv_pyobj() 25 26def button_event(event, CS_box, port_ctrl): 27 port = port_ctrl.GetValue() 28 CS_select = CS_box.GetSelection() 29 30 if CS_select == 0: 31 #ここで動作が停止する。 32 server = server_bind(port) 33 print(server_recv(server, "client君こんばんは(´・ω・`)")) 34 else: 35 #ここで動作が停止する。 36 client = client_connect(port) 37 print(client_recv(client, "server君こんにちは(´・ω・`)")) 38 39if __name__ == "__main__": 40 app = wx.App() 41 42 frame = wx.Frame(None, wx.ID_ANY, "test") 43 panel = wx.Panel(frame, wx.ID_ANY) 44 45 CS_box = wx.RadioBox(panel, wx.ID_ANY, pos=(0, 0), 46 choices=["server", "client"]) 47 48 port_ctrl = wx.TextCtrl(panel, wx.ID_ANY, size=(40, 21), pos=(0, 50)) 49 port_ctrl.SetMaxLength(4) 50 port_ctrl.SetValue("1234") 51 52 button = wx.Button(panel, wx.ID_ANY, "接続", pos=(0, 85)) 53 event = lambda event:button_event(event, CS_box, port_ctrl) 54 button.Bind(wx.EVT_BUTTON, event) 55 56 frame.Show() 57 app.MainLoop()
問題の部分を絞って書いたつもりですが、長かったらすいません。
button_event関数を実行すると#ここで動作が停止する。とコメントに書かれてある部分で、
windowの移動がままならなくなったり、閉じようとした時に動作が停止しましたと表示されます。
wxpythonとzmqが入っていればコピペで動きますのでどういう感じか見てもらえればわかるかと思います。
もう片方が接続すればすぐに動くようになり、メッセージ交換も成功しますが、
中止して閉じたい時や、windowをちょっと動かしたい時などに不便だなあと感じているのですが、どう解決したらいいのか悩んでいます。
解決策の提案、ご教授を頂けたら嬉しいです。
動作停止が解決したコード
python
1#メッセージ交換に使用する関数 2def server_bind(port): 3 context = zmq.Context() 4 server = context.socket(zmq.REP) 5 server.bind("tcp://127.0.0.1:" + str(port)) 6 return server 7 8def client_connect(port): 9 context = zmq.Context() 10 client = context.socket(zmq.REQ) 11 client.connect("tcp://127.0.0.1:" + str(port)) 12 return client 13 14def server_recv(server, y, text_ctrl): 15 recv = server.recv_pyobj() 16 send = server.send_pyobj(y) 17 text_ctrl.SetValue(recv) 18 19def client_recv(client, y, text_ctrl): 20 send = client.send_pyobj(y) 21 recv = client.recv_pyobj() 22 text_ctrl.SetValue(recv) 23 24def button_event(event, CS_box, port_ctrl, text_ctrl): 25 port = port_ctrl.GetValue() 26 CS_select = CS_box.GetSelection() 27 28 if CS_select == 0: 29 server = server_bind(port) 30 s_recv = threading.Thread(target=server_recv, 31 args=(server, 32 "client君やあ(´・ω・`)", 33 text_ctrl)) 34 s_recv.start() 35 else: 36 client = client_connect(port) 37 c_recv = threading.Thread(target=client_recv, 38 args=(client, 39 "server君やあ(´・ω・`)", 40 text_ctrl)) 41 c_recv.start() 42 43if __name__ == "__main__": 44 app = wx.App() 45 46 frame = wx.Frame(None, wx.ID_ANY, "test") 47 panel = wx.Panel(frame, wx.ID_ANY) 48 49 CS_box = wx.RadioBox(panel, wx.ID_ANY, pos=(0, 0), 50 choices=["server", "client"]) 51 52 port_ctrl = wx.TextCtrl(panel, wx.ID_ANY, size=(40, 21), pos=(0, 50)) 53 port_ctrl.SetMaxLength(4) 54 port_ctrl.SetValue("1234") 55 56 text_ctrl = wx.TextCtrl(panel, wx.ID_ANY, pos=(0, 120)) 57 58 button = wx.Button(panel, wx.ID_ANY, "接続", pos=(0, 85)) 59 event = lambda event:button_event(event, CS_box, port_ctrl, text_ctrl) 60 button.Bind(wx.EVT_BUTTON, event) 61 62 frame.Show() 63 app.MainLoop()
回答1件
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。
退会済みユーザー
2017/12/20 16:41
退会済みユーザー
2017/12/22 16:26