所有的连接把收到的数据放到Queue里，然后单独启动一个线程循环取Queue里的数据进行存储。
Quote: 引用 1 楼 wqc5461 的回复: 所有的连接把收到的数据放到Queue里，然后单独启动一个线程循环取Queue里的数据进行存储。 现在是这样的处理机制，连接少可以，但是连接数一多入库的速度就跟不上接收速度！
Quote: 引用 3 楼 a8282542 的回复: Quote: 引用 1 楼 wqc5461 的回复: 所有的连接把收到的数据放到Queue里，然后单独启动一个线程循环取Queue里的数据进行存储。 现在是这样的处理机制，连接少可以，但是连接数一多入库的速度就跟不上接收速度！ 那就用线程池多启动几个这样的线程。
Quote: 引用 4 楼 wqc5461 的回复: Quote: 引用 3 楼 a8282542 的回复: Quote: 引用 1 楼 wqc5461 的回复: 所有的连接把收到的数据放到Queue里，然后单独启动一个线程循环取Queue里的数据进行存储。 现在是这样的处理机制，连接少可以，但是连接数一多入库的速度就跟不上接收速度！ 那就用线程池多启动几个这样的线程。 入库已经开启多个线程了，但是每秒只能处理70-80个
京公网安备 11010802041100号