首頁猿問套接字聊天室 - python 3.7

套接字聊天室 - python 3.7

Python

牛魔王的故事 2021-11-02 19:35:09

這是我一直在開發(fā)的python聊天室，它使您可以通過python與同一網(wǎng)絡(luò)上的其他人聊天主持人：import socketimport sysimport times = socket.socket()host = socket.gethostname()port = 8080s.bind((host,port))print("")print("Sever adress is", host)print("")name = input(str("Please enter your username : "))s.listen(1)print("")print("Waiting for any incoming connections ... ")print("")conn, addr = s.accept()print("Recieved connection")#connection done ###s_name = conn.recv(1024)s_name = s_name.decode()print("")print(s_name, "has connected to the chat room")print("")conn.send(name.encode())## messaging loop ##while 1: message = input(str("Please enter enter your message : ")) print("") conn.send(message.encode()) message = conn.recv(1024) message = message.decode() print("") print(name,": ",message) print("")客戶：import socketimport sysimport timeprint("Welcome to python chat ")print("")print("Initiallsing....")time.sleep(1)s = socket.socket()print("")host = input(str("Please enter server adress : "))print("")name = input(str("Please enter your name : "))port = 8080print("")time.sleep(1)s.connect((host,port))print("Connected...")## Conection done ##s.send(name.encode())s_name = s.recv(1024)s_name = s_name.decode()print("")print( s_name, "has joined the chat room ")while 1: message = s.recv(1024) message = message.decode() print("") print(name,": ",message) print("") message = input(str("Please enter your enter message : ")) print("") s.send(message.encode())我有兩個(gè)問題，第一個(gè)問題是它一次只允許一個(gè)人說話，我的意思是說如果你先發(fā)送一條消息，你將不被允許發(fā)送另一條消息，直到另一個(gè)人回應(yīng). 第二個(gè)問題是此代碼僅適用于 2 個(gè)用戶，我希望它適用于多個(gè)用戶

查看完整描述

3 回答

躍然一笑

TA貢獻(xiàn)1826條經(jīng)驗(yàn) 獲得超6個(gè)贊

您需要為發(fā)送和接收創(chuàng)建兩個(gè)單獨(dú)的線程。您編寫循環(huán)的方式不適用于同時(shí)進(jìn)行雙向通信。因?yàn)樵诎l(fā)送消息后，循環(huán)正在等待接收某些東西。[如果您想通過互聯(lián)網(wǎng)運(yùn)行代碼，請(qǐng)?zhí)鎿Qlocalhost為所需的 IP 地址行HOST = 'localhost'] 讓我分享一個(gè)解決方案（這是我在 TAing 本科網(wǎng)絡(luò)課程時(shí)完成的示例解決方案）：

我已經(jīng)在 Linux 機(jī)器（Ubuntu 18.04）上測(cè)試了代碼。我有學(xué)生在他們的 Mac 上成功運(yùn)行了這個(gè)。我不確定它是否在 Windows 機(jī)器上運(yùn)行。即使它在 Windows 機(jī)器上不起作用，一些小的修改也應(yīng)該可以解決問題。

服務(wù)端代碼（你需要先運(yùn)行這個(gè)）： chatServerDuplex.py

# Import socket module

from socket import *

import threading

import sys # In order to terminate the program

FLAG = False # this is a flag variable for checking quit

# function for receiving message from client

def recv_from_client(conn):

global FLAG

try:

# Receives the request message from the client

while True:

if FLAG == True:

break

message = conn.recv(1024).decode()

# if 'q' is received from the client the server quits

if message == 'q':

conn.send('q'.encode())

print('Closing connection')

conn.close()

FLAG = True

break

print('Client: ' + message)

except:

conn.close()

# function for receiving message from client

def send_to_client(conn):

global FLAG

try:

while True:

if FLAG == True:

break

send_msg = input('')

# the server can provide 'q' as an input if it wish to quit

if send_msg == 'q':

conn.send('q'.encode())

print('Closing connection')

conn.close()

FLAG = True

break

conn.send(send_msg.encode())

except:

conn.close()

# this is main function

def main():

threads = []

global FLAG

# TODO (1) - define HOST name, this would be an IP address or 'localhost' (1 line)

HOST = 'localhost'

# TODO (2) - define PORT number (1 line) (Google, what should be a valid port number)

# make sure the ports are not used for any other application

serverPort = 6789

# Create a TCP server socket

#(AF_INET is used for IPv4 protocols)

#(SOCK_STREAM is used for TCP)

# TODO (3) - CREATE a socket for IPv4 TCP connection (1 line)

serverSocket = socket(AF_INET, SOCK_STREAM)

# Bind the socket to server address and server port

# TODO (4) - bind the socket for HOSR and serverPort (1 line)

serverSocket.bind((HOST, serverPort))

# Listen to at most 1 connection at a time

# TODO (5) - listen and wait for request from client (1 line)

serverSocket.listen(1)

# Server should be up and running and listening to the incoming connections

print('The chat server is ready to connect to a chat client')

# TODO (6) - accept any connection request from a client (1 line)

connectionSocket, addr = serverSocket.accept()

print('Sever is connected with a chat client\n')

t_rcv = threading.Thread(target=recv_from_client, args=(connectionSocket,))

t_send = threading.Thread(target=send_to_client, args=(connectionSocket,))

# call the function to receive message server

#recv_from_server(clientSocket)

threads.append(t_rcv)

threads.append(t_send)

t_rcv.start()

t_send.start()

t_rcv.join()

t_send.join()

# closing serverScoket before exiting

print('EXITING')

serverSocket.close()

#Terminate the program after sending the corresponding data

sys.exit()

# This is where the program starts

if __name__ == '__main__':

main()

客戶端代碼： chatClientDuplex.py

from socket import *

import threading

import sys

FLAG = False # this is a flag variable for checking quit

# function for receiving message from client

def send_to_server(clsock):

global FLAG

while True:

if FLAG == True:

break

send_msg = input('')

clsock.sendall(send_msg.encode())

# function for receiving message from server

def recv_from_server(clsock):

global FLAG

while True:

data = clsock.recv(1024).decode()

if data == 'q':

print('Closing connection')

FLAG = True

break

print('Server: ' + data)

# this is main function

def main():

threads = []

# TODO (1) - define HOST name, this would be an IP address or 'localhost' (1 line)

HOST = 'localhost' # The server's hostname or IP address

# TODO (2) - define PORT number (1 line) (Google, what should be a valid port number)

PORT = 6789 # The port used by the server

# Create a TCP client socket

#(AF_INET is used for IPv4 protocols)

#(SOCK_STREAM is used for TCP)

# TODO (3) - CREATE a socket for IPv4 TCP connection (1 line)

clientSocket = socket(AF_INET, SOCK_STREAM)

# request to connect sent to server defined by HOST and PORT

# TODO (4) - request a connection to the server (1 line)

clientSocket.connect((HOST, PORT))

print('Client is connected to a chat sever!\n')

# call the function to send message to server

#send_to_server(clientSocket)

t_send = threading.Thread(target=send_to_server, args=(clientSocket,))

# call the function to receive message server

#recv_from_server(clientSocket)

t_rcv = threading.Thread(target=recv_from_server, args=(clientSocket,))

threads.append(t_send)

threads.append(t_rcv)

t_send.start()

t_rcv.start()

t_send.join()

t_rcv.join()

print('EXITING')

sys.exit()

# This is where the program starts

if __name__ == '__main__':

main()

反對(duì) 回復(fù) 2021-11-02

拉風(fēng)的咖菲貓

TA貢獻(xiàn)1995條經(jīng)驗(yàn) 獲得超2個(gè)贊

System123456 問題是當(dāng)服務(wù)器偵聽并且客戶端連接到它時(shí)，您構(gòu)建了一個(gè)客戶端 - 服務(wù)器系統(tǒng)。嘗試查看點(diǎn)對(duì)點(diǎn)系統(tǒng)，而不是每個(gè)節(jié)點(diǎn)都是平等的。為了構(gòu)建聊天室，您可能會(huì)查看 DHT 節(jié)點(diǎn)。

反對(duì) 回復(fù) 2021-11-02