zy820 最近的时间轴更新 zy820 最近的时间轴更新 |
zy820V2EX 第 303783 号会员，加入于 2018-03-27 15:34:11 +08:00 |
| socketserver.server_forever()+多线程处理数据并存入数据库 Python • zy820 • 2018-08-03 10:57:35 AM • 最后回复来自 zy820 | 1 |
| socket server 接收数据，用 queue+sql 多线程处理问题
1 问与答 • zy820 • 2018-08-02 13:39:06 PM • 最后回复来自 zy820
|
2 |
| b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） 问与答 • zy820 • 2018-07-25 16:06:55 PM • 最后回复来自 zy820 | 12 |
| Python socketserver 写个 TCP server 接收数据 问与答 • zy820 • 2018-07-23 22:11:45 PM • 最后回复来自 verrickt | 7 |
| 我用阿里云 ECS 写个 tcp server 接收 GSM 数据，但是总是有一些国外 IP 连接导致 server 崩了是什么原因，怎么解决 问与答 • zy820 • 2018-07-18 19:21:10 PM • 最后回复来自 zy820 | 8 |
| 现在再做个项目，需要用 flask 写个后台系统接收 TCP 连接传输的数据并显示在页面上
1 Python • zy820 • 2018-07-25 14:08:26 PM • 最后回复来自 zy820
|
18 |
zy820 最近回复了
2018-08-03 10:57:35 +08:00 回复了 zy820 创建的主题 › Python › socketserver.server_forever()+多线程处理数据并存入数据库 |
if __name__ == "__main__":
sensor_que = queue.Queue()
sensor_data = {'DeviceId': '', 'AirPressure': 0, 'Humidity': 0, 'Noise': 0, 'Pm25': 0, 'Temperature': 0,
'WindDirection': 0, 'WindSpeed': 0}
# HOST, PORT = "localhost", 9999 #windows
HOST, PORT = "0.0.0.0", 9999 # Linux
server = socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler) # 线程
server.serve_forever()
print('before init_db!')
connect_sql()
init_db()
print('after init_db!')
for i in range(multiprocessing.cpu_count()):
t = threading.Thread(target=getsensor_que)
t.start()
sensor_que = queue.Queue()
sensor_data = {'DeviceId': '', 'AirPressure': 0, 'Humidity': 0, 'Noise': 0, 'Pm25': 0, 'Temperature': 0,
'WindDirection': 0, 'WindSpeed': 0}
# HOST, PORT = "localhost", 9999 #windows
HOST, PORT = "0.0.0.0", 9999 # Linux
server = socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler) # 线程
server.serve_forever()
print('before init_db!')
connect_sql()
init_db()
print('after init_db!')
for i in range(multiprocessing.cpu_count()):
t = threading.Thread(target=getsensor_que)
t.start()
2018-08-02 13:39:06 +08:00 回复了 zy820 创建的主题 › 问与答 › socket server 接收数据，用 queue+sql 多线程处理问题 |
没有大神指点一下吗
2018-07-26 22:14:01 +08:00 回复了 zy820 创建的主题 › 问与答 › socket server 接收数据，用 queue+sql 多线程处理问题 |
def getsensor_que():
while True:
sensor = sensor_que.get(block=True) #阻塞，queue 为空时，不会 Queue.Empty 异常
print(sensor)
savetosql(sensor)
for i in range(multiprocessing.cpu_count()):
t = threading.Thread(target=getsensor_que)
t.start()
while True:
sensor = sensor_que.get(block=True) #阻塞，queue 为空时，不会 Queue.Empty 异常
print(sensor)
savetosql(sensor)
for i in range(multiprocessing.cpu_count()):
t = threading.Thread(target=getsensor_que)
t.start()
2018-07-25 16:06:55 +08:00 回复了 zy820 创建的主题 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@msg7086 谢谢提醒，我的，目前根据六楼建议已解决
2018-07-25 14:08:26 +08:00 回复了 zy820 创建的主题 › Python › 现在再做个项目，需要用 flask 写个后台系统接收 TCP 连接传输的数据并显示在页面上 |
@copie 不是 websocket 吧，就是 tcp server 端，目前已经接收数据了，下一步存储到数据库
2018-07-25 10:14:26 +08:00 回复了 zy820 创建的主题 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@msg7086 \x00\x00\x03\xe9 四个字节是一个 int 啊，现在接收要把它转化过来
2018-07-24 13:58:13 +08:00 回复了 zy820 创建的主题 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@misaka19000 我觉得也是正在尝试
2018-07-24 13:37:39 +08:00 回复了 zy820 创建的主题 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@imn1 [0]返回的是 int 啊
2018-07-24 13:20:20 +08:00 回复了 zy820 创建的主题 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@GeruzoniAnsasu data=struct.unpack(">ii",b"\x00\x00\x00\x1e")[0] 加个 i 就行了，现在还是保存字节流并提取想要位置的字节问题
2018-07-24 13:06:33 +08:00 回复了 zy820 创建的主题 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@GeruzoniAnsasu data=struct.unpack(">i",b"\x00\x00\x00\x1e")[0]只能有四个字节，现在问题时怎么把 b''字节流保存并截取我想要的字节呢
Select Language