首页
后端开发
Java
使用多线程模拟数据并将其存入数据库的示例

使用多线程模拟数据并将其存入数据库的示例

22 次浏览 0 条评论
rar
rar 
import socket
import threading
import pymysql

# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='password', database='testdb')
cursor = conn.cursor()

# 创建Socket
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('localhost', 8888))
server_socket.listen(5)

# 定义处理客户端请求的函数
def handle_client(client_socket):
    while True:
        # 模拟数据
        data = 'example data'
        # 将数据存入数据库
        sql = 'INSERT INTO data_table (data) VALUES (%s)'
        cursor.execute(sql, (data,))
        conn.commit()

# 接收并处理客户端连接
while True:
    client_socket, address = server_socket.accept()
    # 使用多线程处理客户端请求
    client_thread = threading.Thread(target=handle_client, args=(client_socket,))
    client_thread.start()
rar 文件大小：9.58MB