我需要基于pycharm一个多线程+套接字的开发一个双向通讯的前台点餐、后厨协同系统的代码
时间: 2024-02-22 17:58:44 浏览: 17
好的,以下是一个简单的基于PyCharm的多线程+套接字的双向通讯的前台点餐、后厨协同系统的代码示例,供您参考:
前台点餐系统代码:
```python
import socket
import threading
import json
# 定义服务器地址和端口号
SERVER_ADDRESS = ('localhost', 8888)
# 定义消息类型
MSG_TYPE_ORDER = 'order'
# 定义菜品列表
MENU = ['汉堡', '薯条', '可乐', '雪碧']
# 创建套接字
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 连接服务器
client_socket.connect(SERVER_ADDRESS)
# 发送消息
def send_message():
while True:
# 获取用户输入的订单信息
order = input('请输入您要点的菜品和数量,用逗号分隔:')
items = order.split(',')
if len(items) == 2 and items[0] in MENU:
# 构造订单消息
msg = {'type': MSG_TYPE_ORDER, 'food': items[0], 'quantity': int(items[1])}
# 发送订单消息到服务器
client_socket.sendall(json.dumps(msg).encode())
else:
print('输入有误,请重新输入!')
# 接收消息
def receive_message():
while True:
# 接收服务器发送的消息
data = client_socket.recv(1024)
if data:
msg = json.loads(data.decode())
if msg['type'] == MSG_TYPE_ORDER:
print('您的订单已提交,订单号为:{}'.format(msg['order_id']))
else:
print('收到无法识别的消息!')
# 启动发送和接收消息线程
threading.Thread(target=send_message).start()
threading.Thread(target=receive_message).start()
```
后厨协同系统代码:
```python
import socket
import threading
import json
# 定义服务器地址和端口号
SERVER_ADDRESS = ('localhost', 8888)
# 定义消息类型
MSG_TYPE_ORDER = 'order'
MSG_TYPE_STATUS = 'status'
# 创建套接字
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定地址和端口号
server_socket.bind(SERVER_ADDRESS)
# 监听端口号
server_socket.listen(5)
# 订单号计数器
order_counter = 1
# 处理订单消息
def handle_order(data):
global order_counter
# 解析订单消息
msg = json.loads(data.decode())
food = msg['food']
quantity = msg['quantity']
# 处理订单
order_id = order_counter
order_counter += 1
# 构造订单状态消息
status_msg = {'type': MSG_TYPE_STATUS, 'order_id': order_id, 'status': 'processing'}
# 发送订单状态消息到客户端
conn.sendall(json.dumps(status_msg).encode())
# 模拟制作食物
print('正在制作订单{},{} x {}'.format(order_id, food, quantity))
time.sleep(5)
print('订单{}制作完成!'.format(order_id))
# 构造订单状态消息
status_msg = {'type': MSG_TYPE_STATUS, 'order_id': order_id, 'status': 'completed'}
# 发送订单状态消息到客户端
conn.sendall(json.dumps(status_msg).encode())
# 处理客户端请求
def handle_client(conn, addr):
while True:
# 接收客户端发送的消息
data = conn.recv(1024)
if data:
msg = json.loads(data.decode())
if msg['type'] == MSG_TYPE_ORDER:
handle_order(data)
else:
print('收到无法识别的消息!')
else:
break
# 关闭连接
conn.close()
# 启动服务器
while True:
# 等待客户端连接
conn, addr = server_socket.accept()
print('客户端 {} 已连接'.format(addr))
# 创建新线程处理客户端请求
threading.Thread(target=handle_client, args=(conn, addr)).start()
```
以上代码仅供参考,实际情况下还需要进行优化和完善。需要注意的是,在实际开发中,还需要考虑并发访问、异常处理、数据同步等方面的问题,以确保系统的稳定性和可靠性。