トップに関する質問 Python3 Tkinter Tkinterとソケット通信のサーバの立ち上げ

編集履歴

質問編集履歴

修正

2021/01/25 05:20

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -218,7 +218,7 @@
 # 追記
-try-except追加、daemon化
+try-except追加、daemon化、二重ループに再変更
 ```Python
@@ -334,9 +334,7 @@
         self.s.listen(1)
-        # 参考
-        # https: // techacademy.jp/magazine/19147
         while loop_flag:
@@ -346,15 +344,15 @@
                 print(con, adr)
-                #while loop_flag:
+                while loop_flag:
-                data = con.recv(1024)
+                    data = con.recv(1024)
-                print(data)
+                    print(data)
-                #    if not data:
+                    if not data:
-                #        break
+                        break
                 print("recv")
@@ -374,4 +372,6 @@
     ctrlr = Controller()
 ```

修正

2021/01/25 05:20

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -366,8 +366,6 @@
                 print(e)
-                return

修正

2021/01/25 02:51

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -218,7 +218,7 @@
 # 追記
-close使うように変更
+try-except追加、daemon化
 ```Python
@@ -252,7 +252,7 @@
     def main(self):
-        self.thread = threading.Thread(target=self.loop)
+        self.thread = threading.Thread(target=self.loop, daemon=True)
         self.thread.start()
@@ -286,7 +286,7 @@
         self.svr.s.close()
-        self.thread.join()
+        #self.thread.join()
         self.win.destroy()
@@ -334,24 +334,40 @@
         self.s.listen(1)
+        # 参考
+        # https: // techacademy.jp/magazine/19147
-        while True:
+        while loop_flag:
+            try:
-            con, adr = self.s.accept()
+                con, adr = self.s.accept()
-            print(con, adr)
+                print(con, adr)
-            while loop_flag:
+                #while loop_flag:
                 data = con.recv(1024)
+                print(data)
-                if not data:
+                #    if not data:
-                    break
+                #        break
                 print("recv")
                 rcv_data.put()
+            except Exception as e:
+                print(type(e))
+                print(e)
+                return

修正

2021/01/25 02:48

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -218,7 +218,7 @@
 # 追記
-フラグをグローバル変数に変更、サーバのstart()呼び出し位置変更
+close使うように変更
 ```Python
@@ -238,6 +238,8 @@
 class Controller:
     def __init__(self):
@@ -270,6 +272,8 @@
         self.svr.start(self.rcv_data)
     def close(self):
         global loop_flag
@@ -280,12 +284,16 @@
+        self.svr.s.close()
         self.thread.join()
         self.win.destroy()
 class View:
     def __init__(self, win):
@@ -300,6 +308,10 @@
 # https://techacademy.jp/magazine/19147
 class Server:
     def __init__(self, rcv_data):
@@ -316,29 +328,29 @@
         global loop_flag
-        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+        self.s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-            s.bind((self.ip_adr, self.port))
+        self.s.bind((self.ip_adr, self.port))
-            s.listen(1)
+        self.s.listen(1)
-            while True:
+        while True:
-                con, adr = s.accept()
+            con, adr = self.s.accept()
-                print(con, adr)
+            print(con, adr)
-                while loop_flag:
+            while loop_flag:
-                    data = con.recv(1024)
+                data = con.recv(1024)
-                    if not data:
+                if not data:
-                        break
+                    break
-                    print("recv")
+                print("recv")
-                    rcv_data.put()
+                rcv_data.put()

修正

2021/01/23 08:00

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -218,7 +218,7 @@
 # 追記
-フラグをグローバル変数に変更、スレッドのスタート位置を変更
+フラグをグローバル変数に変更、サーバのstart()呼び出し位置変更
 ```Python
@@ -252,6 +252,8 @@
         self.thread = threading.Thread(target=self.loop)
+        self.thread.start()
         self.win = tk.Tk()
         self.view = View(self.win)
@@ -266,7 +268,7 @@
         self.svr = Server(self.rcv_data)
-        self.svr.start()
+        self.svr.start(self.rcv_data)
     def close(self):

修正

2021/01/23 05:28

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -266,7 +266,7 @@
         self.svr = Server(self.rcv_data)
-        self.thread.start()
+        self.svr.start()
     def close(self):

修正

2021/01/23 05:26

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -308,8 +308,6 @@
         self.buffer_size = 1024
-        self.start(rcv_data)
     def start(self, rcv_data):

追加

2021/01/23 05:20

投稿

person

スコア223

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -213,3 +213,139 @@
 AttributeError: 'Controller' object has no attribute 'svr'
 ```
+# 追記
+フラグをグローバル変数に変更、スレッドのスタート位置を変更
+```Python
+from tkinter import ttk
+import queue
+import socket
+import threading
+import tkinter as tk
+loop_flag = True
+class Controller:
+    def __init__(self):
+        self.rcv_data = queue.Queue()
+        self.main()
+    def main(self):
+        self.thread = threading.Thread(target=self.loop)
+        self.win = tk.Tk()
+        self.view = View(self.win)
+        self.win.protocol("WM_DELETE_WINDOW", self.close)
+        self.win.mainloop()
+    def loop(self):
+        self.svr = Server(self.rcv_data)
+        self.thread.start()
+    def close(self):
+        global loop_flag
+        # サーバ切断したい
+        loop_flag = False
+        self.thread.join()
+        self.win.destroy()
+class View:
+    def __init__(self, win):
+        self.win = win
+        self.win.geometry("400x300")
+# ソケット通信参考
+# https://techacademy.jp/magazine/19147
+class Server:
+    def __init__(self, rcv_data):
+        self.ip_adr = "127.0.0.1"
+        self.port = 50000
+        self.buffer_size = 1024
+        self.start(rcv_data)
+    def start(self, rcv_data):
+        global loop_flag
+        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+            s.bind((self.ip_adr, self.port))
+            s.listen(1)
+            while True:
+                con, adr = s.accept()
+                print(con, adr)
+                while loop_flag:
+                    data = con.recv(1024)
+                    if not data:
+                        break
+                    print("recv")
+                    rcv_data.put()
+if __name__ == "__main__":
+    ctrlr = Controller()
+```