sblig

?服務(wù)器端：

?

?

 // 1. 分配一個(gè) ServerSocketChannel 文件描述符
            serverChannel = ServerSocketChannel.open();

            // 2. 從 ServerSocketChannel里獲取一個(gè)對于的 socket
            serverSocket = serverChannel.socket();

            // 3. 生成一個(gè) Selector
            selector = Selector.open();

            // 4. 把 socket 綁定到端口上
            serverSocket.bind(new InetSocketAddress(iport));

            // 5. serverChannel 未非bolck
            serverChannel.configureBlocking(false);

            // 6. 通過Selector注冊ServerSocketChannel: 只能注冊 accept
            // 而SocketChannel可以注冊CONNENCT,READ,WRITE ; register -> validOps
            // 在各個(gè)子類實(shí)現(xiàn)不同
            serverChannel.register(selector, SelectionKey.OP_ACCEPT);
            while (true) {
			try {
				// 獲得IO準(zhǔn)備就緒的channel數(shù)量
				int n = selector.select();

				// 沒有channel準(zhǔn)備就緒,繼續(xù)執(zhí)行
				if (n == 0) {
					continue;
				}

				// 用一個(gè)iterator返回Selector的selectedkeys
				Iterator it = selector.selectedKeys().iterator();

				// 處理每一個(gè)SelectionKey
				while (it.hasNext()) {
					SelectionKey key = (SelectionKey) it.next();

					// 判斷是否有新的連接到達(dá)
					if (key.isAcceptable()) {
						
						// 返回SelectionKey的ServerSocketChannel
						ServerSocketChannel server = (ServerSocketChannel) key
								.channel();
						System.out.println("有連接");
						SocketChannel channel = server.accept();
						
						registerChannel(selector, channel, SelectionKey.OP_READ);
						
						doWork(channel);
					}

					// 判斷是否有數(shù)據(jù)在此channel里需要讀取
					if (key.isReadable()) {
						processData(key);
					}
				}

				// 刪除 selectedkeys
				it.remove();

			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}

?

?

?

?客戶端：

?

?

  //打開socket通道
		SocketChannel socketChannel = SocketChannel.open();
		//設(shè)置非阻塞方式
		socketChannel.configureBlocking(false);
		//打開選擇器
		Selector selector = Selector.open();
		//注冊連接到服務(wù)器socket動(dòng)作
		socketChannel.register(selector, SelectionKey.OP_CONNECT);
		//連接
		socketChannel.connect( new InetSocketAddress("localhost",9988));
		
		Set<SelectionKey> selectkeySets;
		SelectionKey selectionKey;
		Iterator<SelectionKey> iterator;
		
		//與服務(wù)器通信通道
		SocketChannel clientChannel ;

	       while(true){
			//選擇一組建，其相應(yīng)的通道已為I/O操作準(zhǔn)備就緒
			//此方法執(zhí)行處于阻塞模式的選擇操作
			selector.select(TIME_OUT);
			
			//返回此選擇器的已選擇鍵集。
			selectkeySets = selector.selectedKeys();
			iterator = selectkeySets.iterator();
			
			
			while(iterator.hasNext()){
				selectionKey = iterator.next();
				
				if (selectionKey.isConnectable()) {
                                  clientChannel = (SocketChannel)selectionKey.channel();
					// 判斷此通道上是否正在進(jìn)行連接操作。  
                                  // 完成套接字通道的連接過程。  
					if (clientChannel.isConnectionPending()) {//判斷此通道上是否正在進(jìn)行連接操作
						clientChannel.finishConnect();  //完成套接字通道的連接過程
                                   
                                  }
                                  clientChannel.register(selector, SelectionKey.OP_WRITE);
                            }else if (selectionKey.isReadable()) {
					clientChannel = (SocketChannel)selectionKey.channel();
					//將緩沖區(qū)清空
					receiveBuffer.clear();
					//讀取服務(wù)器發(fā)送來的數(shù)據(jù)庫到緩沖區(qū)
					count = clientChannel.read(receiveBuffer);//count 讀取到的字節(jié)數(shù)
					if (count > 0) {
						clientChannel.register(selector, SelectionKey.OP_WRITE);
					}
                            }else if (selectionKey.isWritable()) {
					sendBuffer.clear();
					clientChannel = (SocketChannel)selectionKey.channel();
					clientChannel.write(sendBuffer);
					System.out.println("客戶端向服務(wù)器發(fā)送數(shù)據(jù):"+sendText);
					clientChannel.register(selector, SelectionKey.OP_READ);
                            }
                     }
                 }

?

已有 0 人發(fā)表留言，猛擊->>這里<<-參與討論


ITeye推薦

• —軟件人才免語言低擔(dān)保 赴美帶薪讀研！—