当前位置: 技术问答>java相关
如何用单线程实现和多个客户机通讯？
来源: 互联网 发布时间：2015-10-05
本文导语: 用java写的服务程序和客户端进行网络连接时，除了为每一个客户连接开一个线程来处理用户数据外，有没有什么方法能做到单路复用？也就是只用两三个线程来完成和多个客户机的连接，好像nio包提供了类似的功能...
用java写的服务程序和客户端进行网络连接时，除了为每一个客户连接开一个线程来处理用户数据外，有没有什么方法能做到单路复用？也就是只用两三个线程来完成和多个客户机的连接，好像nio包提供了类似的功能，但是不太会，谁能写一个简单的例子，谢了！
|
给你一个用NIO的例子：
import java.io.*;
import java.net.*;
import java.nio.*;
import java.nio.channels.*;
import java.util.*;
public class MultiplexingChatServer implements Runnable
{
private int port;
private Vector sockets = new Vector();
private Set closedSockets = new HashSet();
public MultiplexingChatServer( int port ) {
this.port = port;
Thread t = new Thread( this, "MultiplexingChatServer" );
t.start();
}
public void run() {
try {
ServerSocketChannel ssc = ServerSocketChannel.open();
ssc.configureBlocking( false );
ServerSocket ss = ssc.socket();
InetSocketAddress isa = new InetSocketAddress( port );
ss.bind( isa );
Selector selector = Selector.open();
ssc.register( selector, SelectionKey.OP_ACCEPT );
System.out.println( "Listening on port "+port );
ByteBuffer buffer = ByteBuffer.allocate( 4096 );
while (true) {
int numKeys = selector.select();
if (numKeys>0) {
Set skeys = selector.selectedKeys();
Iterator it = skeys.iterator();
while (it.hasNext()) {
SelectionKey rsk = (SelectionKey)it.next();
int rskOps = rsk.readyOps();
if ((rskOps & SelectionKey.OP_ACCEPT) == SelectionKey.OP_ACCEPT) {
Socket socket = ss.accept();
System.out.println( "Connection from "+socket );
sockets.addElement( socket );
SocketChannel sc = socket.getChannel();
sc.configureBlocking( false );
sc.register( selector, SelectionKey.OP_READ );
selector.selectedKeys().remove( rsk );
} else if ((rskOps & SelectionKey.OP_READ) == SelectionKey.OP_READ) {
SocketChannel ch = (SocketChannel)rsk.channel();
selector.selectedKeys().remove( rsk );
buffer.clear();
ch.read( buffer );
buffer.flip();
System.out.println( "Read "+buffer.limit()+ " bytes from "+ch.socket() );
if (buffer.limit()==0) {
System.out.println( "closing on 0 read" );
rsk.cancel();
Socket socket = ch.socket();
close( socket );
} else {
sendToAll( buffer );
}
}
}
removeClosedSockets();
}
}
} catch( IOException ie ) {
ie.printStackTrace();
}
}
// This method is identical to
// PollingChatServer.sendToAll()
private void sendToAll( ByteBuffer bb ) {
for (Enumeration e=sockets.elements(); e.hasMoreElements();) {
Socket socket = null;
try {
socket = (Socket)e.nextElement();
SocketChannel sc = socket.getChannel();
bb.rewind();
while (bb.remaining()>0) {
sc.write( bb );
}
} catch( IOException ie ) {
closedSockets.add( socket );
}
}
}
private void close( Socket socket ) {
closedSockets.add( socket );
}
// This method is identical to
// PollingChatServer.removeClosedSockets()
private void removeClosedSockets() {
for (Iterator it=closedSockets.iterator(); it.hasNext();) {
Socket socket = (Socket)it.next();
sockets.remove( socket );
System.out.println( "Removed "+socket );
}
closedSockets.clear();
}
static public void main( String args[] ) throws Exception {
int port = Integer.parseInt( args[0] );
new MultiplexingChatServer( port );
}
}
您可能感兴趣的文章:
本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术，将尽最大努力为读者提供更好的信息聚合和浏览方式。
本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。
本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。