如何向我的TCP IP服務器中的所有客戶端線程發送消息？

Question

我想在Python中構建一個TCP IP服務器。 我的目標是在客戶端上運行命令。 要運行命令，您必須在服務器中鍵入「cmd命令」。 我從來沒有與線程工作過，現在我似乎無法找到如何發送我想執行到客戶端線程的命令。 任何人都可以指向正確的方向嗎？

我迄今爲止代碼：

import socket 
    import sys 
    from thread import * 

    HOST = '' 
    PORT = 8884 
    clients = 0 
    connected_id = "" 

    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    print 'Socket created' 

    # Bind socket to local host and port 
    try: 
     s.bind((HOST, PORT)) 
    except socket.error, msg: 
     print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1] 
     sys.exit() 

    print 'Socket successfully binded' 

    # Start listening on socket 
    s.listen(10) 
    print 'Socket is listening' 


    # Function for handling connections. 
    def clientthread(conn): 
     # Sending message to connected client 
     conn.sendall('hello') # send only takes string 
     global clients 
     # loop until disconnect 
     while True: 
      # Receiving from client 
      data = conn.recv(1024) 
      if data.lower().find("id=-1") != -1: 
       clients += 1 
       print("new client ID set to " + str(clients)) 
       conn.sendall("SID=" + str(clients)) 
      if not data: 
       break 

     # If client disconnects 
     conn.close() 

    def addclientsthread(sock): 
     # start new thread takes 1st argument as a function name to be run, second is the tuple of arguments to the function 
     conn, addr = sock.accept() 
     print('Client connected on ' + addr[0]) 
     start_new_thread(clientthread, (conn,)) 

    def sendallclients(message): 

     # send msg to all clients 
     tmp = 0 

    # now keep talking with the clients 
    start_new_thread(addclientsthread, (s,)) 
    usr_input = "" 
    while str(usr_input) != "Q": 
     # do stuff 
     usr_input = raw_input("Enter 'Q' to quit") 
     if usr_input.find("cmd") == 0: 
      sendallclients(usr_input[3:]) 
     if usr_input.find("hi") == 0: 
      sendallclients("hey") 
    s.close() 

Answer 1

首先做一個客戶端列表：

my_clients = [] 

然後，您可以修改addclientsthread以將新客戶添加到列表中：

def addclientsthread(sock): 
    global my_clients 
    conn, addr = sock.accept() 
    my_clients += [conn] 
    print('Client connected on ' + addr[0]) 
    start_new_thread(clientthread, (conn,)) 

在 sendallclients功能超過 my_clients

下一個迭代：

def sendallclients(message): 
    for client in my_clients : 
     client.send(message) 

現在所有的客戶端都應該收到message

Answer 2

保持客戶端套接字和循環列表在列表發送每一個命令：

cons = [con1, con2, ...] 
... 
for con in cons: 
    con.send(YOUR_MESSAGE)