pythonでクライアントサーバーシステムを作ってるのですが、GUIで表示されない部分があります。

Question

前提・実現したいこと

クライアントサーバーシステムを構築していて、複数のクライアントの接続ができるようにしてます。あるクライアントがメッセージを送信すると他のクライアントにも送信されたメッセージが表示されるようにしたいです。GUIを使ってやっています。

しかし、発言を押しても表示されません。どこが間違っているか教えてほしいです。

該当のソースコード

サーバー側
# -*- coding: utf-8 -*-

import socket
import select

def send_to(sock,msg):
    try:
        sock.send(msg.encode())
        return True
    except:
        sock.close()
        return False
    
def broadcast(socklist,msg):
    for sock in socklist:
        if not send_to(sock,msg):
            sock_list.remove(sock)
            
host='127.0.0.1'
port=50000
backlog=10
bufsize=4096

server_sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
print("socket is created")

try:
    server_sock.bind((host,port))
    print("socket bind")
    server_sock.listen(backlog)
    print("socket listen")
    sock_list=[server_sock]
    client_sock_table={}
    while True:
        r_ready_sockets,w_ready_sockets,e_ready_sockets=select.select(sock_list,[],[])
        for sock in r_ready_sockets:
            if sock==server_sock:
                conn,address=sock.accept()
                sock_list.append(conn)
                client_sock_table[address[1]]=conn
                sock_list.remove(server_sock)
                broadcast(sock_list,"ポート" + str(address[1]) + "番のユーザーが接続しました")
                sock_list.append(server_sock)
                print(str(address)+"is connected")
            else:
                try:
                    b_msg=sock.recv(bufsize)
                    msg=b_msg.decode('utf-8')
                    if len(msg)==0:
                        sock.close()
                        sock_list.remove(sock)
                    else:
                        sender_port=None
                        for key,val in client_sock_table.items():
                            if val==sock:
                                sender_port=key
                                break
                            if sender_port is not None:
                                sock_list.remove(server_sock)
                                broadcast(sock_list,str(sender_port)+":" + msg)
                                sock_list.append(server_sock)
                except:
                    sock.close()
                    sock_list.remove(sock)
                    sock_list.remove(server_sock)
                    broadcast(sock_list,"someone disconnected")
                    sock_list.append(server_sock)
except Exception as e:
    print("Exception!")
    print(e)
    server_sock.close()
            


クライアント側
# -*- coding: utf-8 -*-

import tkinter as tk
import socket, select
import threading

def send_msg(ev=None):
    if len(entered_txt.get())<=0:
        return
    sock.send(entered_txt.get().encode())
    etr.delete(0,tk.END)
    
def receive_msg(msg):
    if text_w is None:
        return
    text_w.configure(state=tk.NORMAL)
    text_w.insert(tk.END,msg+"\n")
    text_w.configure(state=tk.DISABLED)
    text_w.see(tk.END)
    
#サーバーから送られてきたメッセージをストックする
def stock_msg(msg):
    stocked_msg.append(msg)
    
#ストックされたメッセージに対してreceive_msgを呼び出す
def check_msg():
    while len(stocked_msg)>0:
        receive_msg(stocked_msg.pop(0))
    #after(time.func)
    #funcの実行(呼び出し)をtime[ミリ秒]ごとに行う
    text_w.after(200,check_msg)

root=tk.Tk(None)
root.title("サンプルチャット")

frame=tk.Frame(master=root,width=480,height=320)

label1=tk.Label(master=frame,text="サンプルチャット",font=('メイリオ','12'),bg="#cccccc")
label1.place(relx=0,rely=0,relwidth=1.0,relheight=0.1)

#複数行テキスト
text_w=tk.Text(master=frame,state=tk.DISABLED,font=('メイリオ','10'),bg="white")
text_w.place(relx=0.05,rely=0.1,relwidth=0.85,relheight=0.7)

#スクロールバー
sb_y=tk.Scrollbar(master=frame,orient=tk.VERTICAL,command=text_w.yview)
sb_y.place(relx=0.90,rely=0.1,relwidth=0.05,relheight=0.7)
text_w.config(yscrollcommand=sb_y.set)

entered_txt=tk.StringVar()
#1行編集テキスト
etr=tk.Entry(master=frame,width=30,textvariable=entered_txt)
etr.bind('<Return>',send_msg)
etr.place(relx=0.05,rely=0.85,relwidth=0.65,relheight=0.1)

#ボタン
bt=tk.Button(master=frame,text='発言',bg='skyblue',command=send_msg)
bt.place(relx=0.75,rely=0.85,relwidth=0.35,relheight=0.1)

frame.pack()

host='127.0.0.1'
port=50000
bufsize=4096

sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)

#送られてきたメッセージをストックするためのリスト
stocked_msg=[]

def listen():
    try:
        sock.connect((host,port))
        while True:
            r_ready_sockets,w_ready_sockets,e_ready_sockets=select.select([sock],[],[])
            try:
                recev_msg=sock.recv(bufsize).decode()
            except:
                break
            stock_msg(recev_msg)
    except Exception as e:
        print(e)
    finally:
        sock.close()
        receive_msg('サーバとの接続が切断されました')
check_msg()

thrd=threading.Thread(target=listen)
thrd.start()

root.mainloop()

            

試したこと

ここに問題に対して試したことを記載してください。

補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。

Answer 1

server側のbreakとその次の行を削除すれば良いです。

break
if sender_port is not None:

forループから抜けてしまって永遠にbroadcastされないです。

Comments

[asdfghjklz]

そこのインデントを左にずらしたらできました。ありがとうございます。