Linux多人聊天室 在线列表的代码
时间: 2024-02-19 22:59:02 浏览: 48
多人聊天室源代码
4星 · 用户满意度95%
实现一个 Linux 多人聊天室,在线列表的代码需要涉及以下几个方面:
1. 客户端连接服务器后,需要向服务器发送一个用户昵称,服务器将该昵称存储到在线列表中。
2. 在线列表需要实时更新,当用户上线或下线时,服务器需要及时更新在线列表。
3. 客户端可以通过某个命令或者按钮来查看在线列表。
以下是一个简单的示例代码,可以帮助你实现在线列表的功能:
1. 服务器端代码:
```python
# -*- coding: utf-8 -*-
import socket
import threading
# 存储在线用户的字典
online_users = {}
# 服务器地址和端口
HOST = '127.0.0.1'
PORT = 8888
def handle_client(client_socket, client_address):
"""
处理客户端连接
"""
# 接收客户端发送的昵称
nickname = client_socket.recv(1024).decode('utf-8')
# 将昵称添加到在线列表中
online_users[client_address] = nickname
print('[Server] User {} connected.'.format(nickname))
# 广播用户上线消息
broadcast('[Server] User {} joined the chat room.'.format(nickname))
while True:
try:
# 接收客户端消息
data = client_socket.recv(1024)
if data:
# 广播消息
broadcast('[{}] {}'.format(nickname, data.decode('utf-8')))
else:
# 客户端断开连接
del online_users[client_address]
print('[Server] User {} disconnected.'.format(nickname))
# 广播用户下线消息
broadcast('[Server] User {} left the chat room.'.format(nickname))
break
except:
# 出现异常,客户端断开连接
del online_users[client_address]
print('[Server] User {} disconnected.'.format(nickname))
# 广播用户下线消息
broadcast('[Server] User {} left the chat room.'.format(nickname))
break
def broadcast(message):
"""
广播消息
"""
for client_address in online_users:
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(client_address)
client_socket.send(message.encode('utf-8'))
client_socket.close()
def main():
"""
主函数
"""
# 创建服务器套接字
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind((HOST, PORT))
server_socket.listen(5)
print('[Server] Listening on {}:{}'.format(HOST, PORT))
while True:
# 等待客户端连接
client_socket, client_address = server_socket.accept()
# 创建一个新线程来处理客户端连接
client_thread = threading.Thread(target=handle_client, args=(client_socket, client_address))
client_thread.start()
if __name__ == '__main__':
main()
```
2. 客户端代码:
```python
# -*- coding: utf-8 -*-
import socket
import threading
# 服务器地址和端口
HOST = '127.0.0.1'
PORT = 8888
def receive_data(client_socket):
"""
接收服务器发送的消息
"""
while True:
try:
data = client_socket.recv(1024)
if data:
print(data.decode('utf-8'))
except:
# 出现异常,服务器断开连接
print('[Client] Disconnected from the server.')
client_socket.close()
break
def main():
"""
主函数
"""
# 创建客户端套接字
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect((HOST, PORT))
# 发送昵称
nickname = input('Please input your nickname: ')
client_socket.send(nickname.encode('utf-8'))
# 创建一个新线程来接收服务器发送的消息
receive_thread = threading.Thread(target=receive_data, args=(client_socket,))
receive_thread.start()
while True:
# 显示在线列表
command = input('Input "/list" to show online users: ')
if command == '/list':
print('Online users:')
for user in online_users.values():
print(user)
if __name__ == '__main__':
main()
```
以上代码只是一个简单的示例,实际上还有很多细节需要考虑,比如如何处理用户输入的命令、如何避免重名等。
阅读全文