微科社区,轻松开发从此开始! 请登陆 免费注册

微科社区

当前位置:首页 > Java平台 > J2SE >

如何实现nio监听两个端口,我server设置了7777 77

时间:2014-04-11 20:20  浏览:努力统计中...
importjava.io.IOException; importjava.net.InetSocketAddress; importjava.net.ServerSocket; importjava.net.Socket; importjava.nio.ByteBuffer; importjava.nio.channels.SelectionKey; importjava.nio.channels.Selector; importjava.nio.channels.Serve
import java.io.IOException;  
import java.net.InetSocketAddress;  
import java.net.ServerSocket;  
import java.net.Socket;  
import java.nio.ByteBuffer;  
import java.nio.channels.SelectionKey;  
import java.nio.channels.Selector;  
import java.nio.channels.ServerSocketChannel;  
import java.nio.channels.SocketChannel;  
import java.nio.charset.Charset;  
import java.util.HashMap;  
import java.util.Map;  
import java.util.Set;  
  
public class NIOSServer {  
    private int port = 8888;  
    //解码buffer  
    private Charset cs = Charset.forName("gbk");  
    /*接受数据缓冲区*/  
    private static ByteBuffer sBuffer = ByteBuffer.allocate(1024);  
    /*发送数据缓冲区*/  
    private static ByteBuffer rBuffer = ByteBuffer.allocate(1024);  
    /*映射客户端channel */  
    private Map<String, SocketChannel> clientsMap = new HashMap<String, SocketChannel>();  
    private static Selector selector;  
      
    public NIOSServer(int port){  
        this.port = port;  
        try {  
            init();  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
    private void init() throws IOException{  
        /* 
         *启动服务器端,配置为非阻塞,绑定端口,注册accept事件 
         *ACCEPT事件:当服务端收到客户端连接请求时,触发该事件 
         */  
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();  
        serverSocketChannel.configureBlocking(false);  
        ServerSocket serverSocket = serverSocketChannel.socket();  
        serverSocket.bind(new InetSocketAddress(port));  
        selector = Selector.open();  
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);  
        System.out.println("server start on port:"+port);  
    }  
    /** 
     * 服务器端轮询监听,select方法会一直阻塞直到有相关事件发生或超时 
     */  
    private void listen(){  
        while (true) {  
            try {  
                selector.select();//返回值为本次触发的事件数  
                Set<SelectionKey> selectionKeys = selector.selectedKeys();  
                for(SelectionKey key : selectionKeys){  
                    handle(key);  
                }  
顶一下
(0)
0%
踩一下
(0)
0%
------分隔线------