python socket服务在百度里90%以上都是一对一聊天,而且客户端仅仅在发送完消息之后就被关闭,无法保持长连接
在服务器开发中，我们必须长时间绑定且知道某一个客户端连接是哪一个用户
接下来为大家提供服务端的写法及思路
- 首先整个脚本需要引入的内容为:
socket 为套接字通迅库
Thread 为线程类在threading库中
# -*- coding: utf-8 -*-
import socket
from threading import Thread
- 接下来是开发流程及思路,首先我们得声明一些在开发中所需要用到的参数
# 消息服务地址
MSG_ADDRESS = ('', 9850)
# 消息服务套接字
msg_server_socket = None
# 消息服务连接池
msg_conn_pool = []
# 消息服务消息最大长度 1024字节
MSG_BUF_SIZE = 1024
- 在上述声明中，设置了客户端消息的文本长度1024以及设定了一个客户端的连接池和消息服务的地址9850。接下来我们需要的就是创建套接字以及使用它了
def msg_init():
"""
消息服务初始化
:return:
"""
global msg_server_socket
# 创建socket对象
msg_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
msg_server_socket.bind(MSG_ADDRESS)
# 线程最大等待数 - 非最大连接数
msg_server_socket.listen(5)
print('消息服务已启动,等待客户端连接...')
def msg_message_handle(client):
"""
消息服务-消息处理逻辑
:param client:
:return:
"""
while True:
msg = client.recv(MSG_BUF_SIZE)
print('客户端-索引', msg_conn_pool.index(client), ' 发送消息:', msg.decode(encoding='utf-8'))
# 客户端消息进行解码
response = msg.decode(encoding='utf-8')
response = response + '服务器处理后结果'
# 编写其他处理方法进行对客户端消息处理
# 将处理后的消息进行encode转码然后进行发送给对应客户端
client.sendall(response.encode(encoding='utf-8'))
if not msg or len(msg) == 0:
client.close()
print('客户端', msg_conn_pool.index(client), '退出')
msg_conn_pool.remove(client)
break
def msg_accept_client():
"""
接收到新的连接
:return:
"""
while True:
# 等待客户端连接
client, _ = msg_server_socket.accept()
# 将接收到的客户端添加到连接池
msg_conn_pool.append(client)
# 给每个客户端创建独立的线程进行管理
thread = Thread(target=msg_message_handle, args=(client,))
# 设置为守护线程
thread.setDaemon(True)
thread.start()
def io_msg_run():
msg_init()
# 新开一个线程,用于接收新的连接
thread = Thread(target=msg_accept_client)
thread.setDaemon(True)
thread.start()
print('消息服务被启动')
print('使用help指令查看该服务所有指令')
while True:
cmd = input()
if cmd == 'userSize':
print('当前消息中心在线人数:', len(msg_conn_pool))
elif cmd == 'sendMsg':
index, msg = input('请输入“索引,消息”的形式:').split(',')
msg_conn_pool[int(index)].sendall(msg.encode(encoding='utf-8'))
elif cmd == 'sendAll':
send_all_msg = input('请输入需发送的消息:')
for cl in msg_conn_pool:
cl.sendall(send_all_msg.encode(encoding='utf-8'))
elif cmd == 'exit':
exit()
elif cmd == 'help':
print('userSize -> 查看当前服务在线人数')
print('sendMsg -> 给对应客户端发送消息')
print('sendAll -> 给所有客户端发送消息')
print('exit -> 退出服务')
print('help -> 查看帮助')
- 上述就是服务端的写法及思路了，接下来为了校验及因为服务端可能回不定时对客户端某一用户或所有用户进行处理,所以客户端其实是分为接收和发送两端逻辑线程的,客户端写法如下:
# -*- coding: utf-8 -*-
import socket
from threading import Thread
BUF_SIZE = 1024
def message_accept(_client):
while True:
response = _client.recv(BUF_SIZE)
print('\n服务器消息:', response.decode(encoding='utf-8'))
if __name__ == '__main__':
ADDR = ('localhost', 9850)
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
client.connect(ADDR)
thread = Thread(target=message_accept, args=(client,))
thread.setDaemon(True)
thread.start()
while True:
data = input('请输入消息:')
client.sendall(data.encode(encoding='utf-8'))
以上就是python tcp/ip游戏服务器消息通迅的基础解决方案了
如有疑问请在下方留言评论谢谢
