Отправка сообщений socket

Server:
conns = []
sip = ""
sp = 555
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((sip, sp))
server.listen()
def message():
 while True:
  cmd = input('Команда: ')
  if cmd == 'msg':
   th = input('Тема сообщения: ')
   content = input('Текст: ')
   for x in conns:
    x.send(str.encode('msg'))
    x.send(str.encode(th))
    x.send(str.encode(content))
 
 
def connect():
 while True:
  global conn, addr
  conn, addr = server.accept()
  conns.append(conn)
  threading.Thread(target=message).start()
 
Client:
ip = "127.0.0.1"
port = 555   
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect((ip, port))
while True:
    data = client.recv(1024).decode("utf-8")
    if data == 'msg':
        th = str(client.recv(1024), "utf-8")
        content = str(client.recv(1024), "utf-8")
        print(f'Сообщение от администратора\nТема: {th}\n{content}')

from functools import partial
import signal
import socket
import threading
 
 
def my_tcp_server(server, clients):
    # Thread running this code accepts
    # connections and adds them to the list
    try:
        while True:
            conn, _ = server.accept()
            clients.append(conn)
    except ConnectionAbortedError as e:
        pass
 
 
def signal_handler(server, clients, signum, frame):
    # When server is Keyboard Interrupted, this code
    # disconnects clients and closes socket
    if clients:
        print("\nDisconnecting clients")
    for c in clients:
        c.close()
    print("\nShutting down server...")
    server.close()
    exit(0)
 
 
if __name__ == "__main__":
    ip = ""
    port = 555
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    server.bind((ip, port))
    server.listen()
 
    clients = []
 
    threading.Thread(target=my_tcp_server, args=(server, clients)).start()
    signal.signal(signal.SIGINT, partial(signal_handler, server, clients))
 
    while True:
        try:
            msg = input("Send message:")
            for c in clients:
                c.send(msg.encode('utf-8'))
        except BrokenPipeError:
            # client got disconnected?
            print(f"Couldn't send message to client {c.fileno()}, removing.")
            c.close()
            clients.remove(c)

import socket
 
 
ip = "127.0.0.1"
port = 555
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect((ip, port))
 
while True:
    try:
        data = client.recv(1024).decode("utf-8")
        if not data:
            print("Disconnected")
            break
        print(f'Сообщение от администратора: {data}')
    except KeyboardInterrupt:
        print("\nShutting down client...")
        break

    while True:
        try:
            msg = input("Send message:")
 
            if msg.startswith('ip'):
                _, ip, msg = msg.split(maxsplit=2)
                for c in clients:
                    if c.getpeername()[0] == ip:
                        c.send(msg.encode('utf-8'))
                        break
            else:
                for c in clients:
                    c.send(msg.encode('utf-8'))
        except BrokenPipeError:
            # client got disconnected?
            print(f"Couldn't send message to client {c.fileno()}, removing.")
            c.close()
            clients.remove(c)