树莓派使用socket发送数据到PC，并存入数据库

Posted 2023-02-05 勾小芬

将传感器监测到的数据通过树莓派传递给PC，使用树莓派作为客户端，用socket向服务器端（PC）发送数据，通过pymysql将接收的数据插入本地数据库。
硬件准备：
树莓派4B／网线
因为是局域网通信，所以网线要连PC或路由器。如果要通过无线通信，可以搭建一个云服务器，通过调用云服务器实现。
软件
运行程序时，先运行服务端，再运行客户端
服务端（PC）

#!/bin/python
#server.py
import pymysql  
import socket
import time

HOST = '192.168.137.1'
PORT = 8888
ADDR = (HOST, PORT)

mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
mySocket.bind(ADDR)
mySocket.listen(4)

# 打开数据库连接
db = pymysql.connect(
	host = 'localhost'
	port = 3306
	passwd = '123456'
	db = 'skdb'
	charset = 'utf8'
)
cursor = db.cursor()
sqltime = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))

while True:
	conn, addr = mySocket.accept()  #接收客户端连接
	print('IP:%s, Port:%s', addr[0], addr[1])
	while True:
		msg = conn.recv(1024)  # 读消息
		print(msg.decode('utf-8'))  #数据解码
		sql = "INSERT INTO MAGNETISM(MFLAG) VALUES ('%s')" % (msg.decode('utf-8'))
		# sql = "INSERT INTO MAGNETISM(MTIME, MFLAG) VALUES ('%s, %s)" % (sqltime, msg.decode('utf-8'))

		try:
			cursor.execute(sql)  #执行sql语句
			db.commit()  # 提交到数据库执行
		except:
			db.rollback()

		time.sleep(10)

		if msg == "over":
			conn.close()
			mySocket.close()
			db.close()
			exit()

客户端（树莓派）

# client.py
import socket
import time

mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
HOST = 192.168.137.1'
PORT = 8888

try:
	mySocket.connect((HOST, PORT))
except:
	print('connect failed')

while True:
	msg = '9'
	mySocket.send(msg.encode('utf-8'))
	
	time.sleep(10)
	if msg == "over":
		mySocket.close()
		exit()

功能：每隔10s，客户端（树莓派）向服务端（PC）发送模拟数据9，服务端接收到后，将其存入mysql数据库中。