zy820's recent timeline updates zy820's recent timeline updates |
zy820V2EX member #303783, joined on 2018-03-27 15:34:11 +08:00 |
| socketserver.server_forever()+多线程处理数据并存入数据库 Python • zy820 • Aug 3, 2018 • Lastly replied by zy820 | 1 |
| socket server 接收数据，用 queue+sql 多线程处理问题
1 问与答 • zy820 • Aug 2, 2018 • Lastly replied by zy820
|
2 |
| b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） 问与答 • zy820 • Jul 25, 2018 • Lastly replied by zy820 | 12 |
| Python socketserver 写个 TCP server 接收数据 问与答 • zy820 • Jul 23, 2018 • Lastly replied by verrickt | 7 |
| 我用阿里云 ECS 写个 tcp server 接收 GSM 数据，但是总是有一些国外 IP 连接导致 server 崩了是什么原因，怎么解决 问与答 • zy820 • Jul 18, 2018 • Lastly replied by zy820 | 8 |
| 现在再做个项目，需要用 flask 写个后台系统接收 TCP 连接传输的数据并显示在页面上
1 Python • zy820 • Jul 25, 2018 • Lastly replied by zy820
|
18 |
zy820's recent replies
Aug 3, 2018 Replied to a topic by 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()
Aug 2, 2018 Replied to a topic by zy820 › 问与答 › socket server 接收数据，用 queue+sql 多线程处理问题 |
没有大神指点一下吗
Jul 26, 2018 Replied to a topic by 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()
Jul 25, 2018 Replied to a topic by zy820 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@msg7086 谢谢提醒，我的，目前根据六楼建议已解决
Jul 25, 2018 Replied to a topic by zy820 › Python › 现在再做个项目，需要用 flask 写个后台系统接收 TCP 连接传输的数据并显示在页面上 |
@copie 不是 websocket 吧，就是 tcp server 端，目前已经接收数据了，下一步存储到数据库
Jul 25, 2018 Replied to a topic by zy820 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@msg7086 \x00\x00\x03\xe9 四个字节是一个 int 啊，现在接收要把它转化过来
Jul 24, 2018 Replied to a topic by zy820 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@misaka19000 我觉得也是正在尝试
Jul 24, 2018 Replied to a topic by zy820 › 问与答 › b'#\x00\x00\x03\xe9\x00\x00\x00\x1e#'怎么保存并读取到每个字节，[0]和 bytearray 返回的都是 int（我想将每四个字节转化为 int） |
@imn1 [0]返回的是 int 啊
Jul 24, 2018 Replied to a topic by 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 就行了，现在还是保存字节流并提取想要位置的字节问题
Jul 24, 2018 Replied to a topic by 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