java nio 服务器无限读

0 0

java nio 服务器无限读3

下弟我这个星期编写一个 java nio 的服务器，用于接受硬件的socket请求.
当时注册过一个读后，客户端发送一条信息，服务器就无限读。看下面代码

package com.nelab.socket;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Set;

import com.nelab.socket.reader.Reader;

public class NIOServer implements Runnable {

	private ServerSocketChannel sschannel;

	private static Selector selector;
	
	

	public NIOServer(int port) throws IOException {
		selector = Selector.open();
		sschannel = ServerSocketChannel.open();
		sschannel.configureBlocking(false);
		sschannel.socket().bind(new InetSocketAddress(port));
		sschannel.register(selector, SelectionKey.OP_ACCEPT);
		Notifier.getNotifier();
	}

	@Override
	public void run() {
		System.out.println("server start .... ");
		int num = 0;
		Iterator<SelectionKey> it  ;
		while (true) {
			try {
			num = selector.select();
			if (num > 0) {

			it = set.iterator();
	
			while (it.hasNext()) {
			SelectionKey key = it.next();
			it.remove();
			if (key.isAcceptable()) {
                                            	 ServerSocketChannel ssc = (ServerSocketChannel) key.channel();SocketChannel sc = ssc.accept();			sc.configureBlocking(false);				sc.register(selector, SelectionKey.OP_READ）;				System.out.println("accept");
			} else if (key.isReadable() ) {
				
		SocketChannel channel = (SocketChannel) key.channel();
			/*  这里进行无限读*/
		System.out.println(Reader.readerUTF(channel));
						}else if(key.isWritable()){
							
						}
					}
				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}

	public static void main(String[] args) throws IOException {
		new Thread(new NIOServer(9001)).start();

	}
}

请哪位高手相救啊！

项目工期紧啊

问题补充：上面的代码不够详细。我贴个详细点的 public void run() {   int num = 0;   Iterator<SelectionKey> it  ;   while (true) {    try {      it = set.iterator();      while (it.hasNext()) {       SelectionKey key = it.next();       it.remove();       if (key.isAcceptable()) {        ServerSocketChannel ssc = (ServerSocketChannel) key.channel();        SocketChannel sc = ssc.accept();        sc.configureBlocking(false);        sc.register(selector, SelectionKey.OP_READ);        System.out.println("accept");       } else if (key.isReadable() ) {        SocketChannel channel = (SocketChannel) key.channel();        /*  这里启动线程池去读数据，但是只有channel.read 方法被调用后，key才失效 */       }else if(key.isWritable()){         /* 这里启动线程池去写数据，但是只有key被注册过去写后，key才失效*/       }      }     }    } catch (IOException e) {     e.printStackTrace();    }   } } 在我写注释，启动线程的地方，因为其他线程抢不到运行，key不能失效，所以主线程无限 可读或可写，有什么好的解决方法吗？

领域模型