socket 多线程 并发时会丢数据如何解决?
把存储数据的数据所有的数据结构 换成 线程安全的集合,例如用Vector 而不用 ArrayList 用HashTable 而不用HashMap ,用StringBuilder 而不用StringBuffer;
多线程共有的函数尽量声明为 synchronized ,复杂的数据交互,在线程与线程的时间间隙里面最好不要调用 Threadsleep方法,另外数据的传输,组号采用字节流,而不要采用字符流,文件的读取访问最好使用单例模式。
一般是在服务器端加,没有必要在客户端端加
多线程高并发不容易。因为python的线程虽然是真线程,不过它有GIL。 所以通常会使用twisted工具,高并发就不是难题了。在linux下更容易。
由于windows下不知道socket的复制。所以不能使用多进程管理多个python实例处理一个端口的请求。
所以建议你走另外一条路,使用nginx之类的代理,再通过wsgi连接。
另外一种办法是使用jython, 这是没有GIL锁的。
不过话说回来,高并发并不取决于语言快慢。而在于处理请求的快慢。 如果你的请求处理速度极快,即使10个线程也可以高并发到3000以上。甚至8000都可以做到。
之所以接收数据时发生混乱,是因为,不能通过收到的数据分辨出它是哪个请求对应数据。
处理这类需要在同一个“通道”(socket) 请求不同服务的问题时,一个常见的做法是,在返回的数据中标识出这个数据对应的请求是哪个。
比如,req: id->1,返回是 rsp: id->1; req: id->2,返回是: rsp: id->2
然后,客户端根据返回的 id 找到对应的请求,就可以区分出数据,就不会混乱了。
加锁只是保证同一时间socket 只处理一个请求,不能保证客户端能够正确区分出请求对应的返回数据。
这是肯定的,多线程的网络服务当然会比单线程要慢得多, 每多开启一个线程,系统资源就会多分配一份 特别地,如果多线程之间需要做到线程同步,那就更慢了
但是socket服务器是不可以用单线程来处理客户端请求的,因为IO读写操作总是阻塞的,不可能让一个用户总是等另一个用户处理完了才有机会被处理
异步IO操作是比较好的方法, 如果你需要做的是一些比如网络聊天室, 棋牌游戏等socket服务器, 你可以考虑Apache开源项目MINA框架来做(它封装了NIO), 这个非常简单, 看一下他们的例子程序和说明文档就可以做一个简单的服务端了
0条评论