我開始學習套接字,我在 Youtube 上看到了一個解釋它的視頻,我拿了一些代碼,但我不明白一些行。
import socket
import threading
HOST = 'localhost'
PORT = 9090
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((HOST, PORT))
server.listen()
# Lists For Clients and Their Nicknames
clients = []
nicknames = []
#send message to all clients
def broadcast(message):
for client in clients:
client.send(message)
def handle(client):
while True:
try:
# Broadcasting Messages
message = client.recv(1024)
broadcast(message)
except:
# Removing And Closing Clients
index = clients.index(client)
clients.remove(client)
client.close()
nickname = nicknames[index]
broadcast('{} left!'.format(nickname).encode('ascii'))
nicknames.remove(nickname)
break
def receive():
while True:
# Accept Connection
client, address = server.accept()
print("Connected with {}".format(str(address)))
# Request And Store Nickname
client.send('NICK'.encode('ascii'))
client.send('check it'.encode('ascii'))
nickname = client.recv(1024).decode('ascii')
nicknames.append(nickname)
clients.append(client)
# Print And Broadcast Nickname
print("Nickname is {}".format(nickname))
broadcast("{} joined!".format(nickname).encode('ascii'))
client.send('Connected to server!'.encode('ascii'))
# Start Handling Thread For Client
thread = threading.Thread(target=handle, args=(client,))
thread.start()
receive()
在while回圈中,我不明白為什么客戶端會得到文本-“檢查它”
client.send('check it'.encode('ascii'))
,但他沒有得到文本-“NICK”-client.send('NICK'.encode('ascii'))
uj5u.com熱心網友回復:
您的客戶端代碼應該s.recv用于檢查NICK并發送回客戶端回應,例如:
s.send(input(s.recv(1024).decode('ascii')).encode('ascii'))
- 它接收
NICK, - 提示通過
input詢問客戶輸入和 - 將用戶輸入發送回服務器。
這對我來說很好。這可能是 OP 未包含的客戶端代碼的問題。它適用于下面的客戶端代碼。
import socket
import threading
# separate thread to ask user for input
def send_message(s):
while True:
msg = input('message: ')
if msg == 'exit':
s.close()
break
s.send(msg.encode('ascii'))
def connect():
s = socket.socket()
address = '127.0.0.1'
port = 8080 # port number
s.connect((address, port))
# receives 'NICK', prompts user for input, sends input back to server
s.send(input(s.recv(1024).decode('ascii')).encode('ascii'))
# starts thread to prompt user for messages to broadcast to other users via server
thread = threading.Thread(target=send_message, args=(s,))
thread.start()
# check for messages from the server and print them
while True:
try:
print(s.recv(1024).decode('ascii'))
except:
break
if __name__ == '__main__':
connect()
轉載請註明出處,本文鏈接:https://www.uj5u.com/qukuanlian/441952.html
