<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    當柳上原的風吹向天際的時候...

    真正的快樂來源于創造

      BlogJava :: 首頁 :: 聯系 :: 聚合  :: 管理
      368 Posts :: 1 Stories :: 201 Comments :: 0 Trackbacks
    注意:
    1.NIO主要用于服務端,若用來客戶端相對于它帶來的額外復雜性有點不值得。
    2.用于編碼解碼字符集請根據您的機器缺省字符集進行調整,如GB2312,GBK,UTF-8,UTF-16等,若出現亂碼請更換之。
    3.BufferSize請根據您可能發送接收的最大字符串長度進行相應調整。

    代碼:
    package com.heyang.biz.server.test.nio;

    import java.net.InetSocketAddress;
    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.Iterator;


    /**
     * NIO 服務器
     * 說明:
     * 作者:何楊(heyang78@gmail.com)
     * 創建時間:2011-1-3 下午12:09:02
     * 修改時間:2011-1-3 下午12:09:02
     
    */
    public class NIOServer{
        
    // 本地字符集
        private static final String LocalCharsetName = "gb2312";

        
    // 本地服務器監聽的端口
        private static final int Listenning_Port=8888;
        
        
    // 緩沖區大小
        private static final int Buffer_Size=1024;
        
        
    // 超時時間,單位毫秒
        private static final int TimeOut=3000;
        
        
    public static void main(String[] args) throws Exception{
            
    // 創建一個在本地端口進行監聽的服務Socket信道.并設置為非阻塞方式
            ServerSocketChannel serverChannel=ServerSocketChannel.open();
            serverChannel.socket().bind(
    new InetSocketAddress(Listenning_Port));
            serverChannel.configureBlocking(
    false);
            
            
    // 創建一個選擇器并將serverChannel注冊到它上面
            Selector selector=Selector.open();
            serverChannel.register(selector, SelectionKey.OP_ACCEPT);
            
            
    while(true){
                
    // 等待某個信道就緒
                if(selector.select(TimeOut)==0){
                    System.out.println(
    ".");
                    
    continue;
                }
                
                
    // 獲得就緒信道的鍵迭代器
                Iterator<SelectionKey> keyIter=selector.selectedKeys().iterator();
                
                
    // 使用迭代器進行遍歷就緒信道
                while(keyIter.hasNext()){
                    SelectionKey key
    =keyIter.next();
                    
                    
    // 這種情況是有客戶端連接過來,準備一個clientChannel與之通信
                    if(key.isAcceptable()){
                        SocketChannel clientChannel
    =((ServerSocketChannel)key.channel()).accept();
                        clientChannel.configureBlocking(
    false);
                        clientChannel.register(key.selector(), SelectionKey.OP_READ,ByteBuffer.allocate(Buffer_Size));
                    }
                    
                    
    // 客戶端有寫入時
                    if(key.isReadable()){
                        
    // 獲得與客戶端通信的信道
                        SocketChannel clientChannel=(SocketChannel)key.channel();
                        
                        
    // 得到并重置緩沖區的主要索引值
                        ByteBuffer buffer=(ByteBuffer)key.attachment();
                        buffer.clear();
                        
                        
    // 讀取信息獲得讀取的字節數
                        long bytesRead=clientChannel.read(buffer);
                        
                        
    if(bytesRead==-1){
                          
    // 沒有讀取到內容的情況
                          clientChannel.close();
                        }
                        
    else{
                          
    // 將緩沖區準備為數據傳出狀態
                          buffer.flip();
                          
                          
    // 將獲得字節字符串(使用Charset進行解碼)   
                          String receivedString=Charset.forName(LocalCharsetName).newDecoder().decode(buffer).toString();
                          
                          
    // 控制臺打印出來
                          System.out.println("接收到信息:"+receivedString);
                          
                          
    // 準備發送的文本
                          String sendString="你好,客戶端. 已經收到你的信息"+receivedString;
                          
                          
    // 將要發送的字符串編碼(使用Charset進行編碼)后再進行包裝
                          buffer=ByteBuffer.wrap(sendString.getBytes(LocalCharsetName));
                          
                          
    // 發送回去
                          clientChannel.write(buffer);
                          
                          
    // 設置為下一次讀取或是寫入做準備
                          key.interestOps(SelectionKey.OP_READ | SelectionKey.OP_WRITE);
                        }
                    }
                    
                    keyIter.remove();
                }
            }
            
        }
    }

    與之配合的客戶端代碼,沒有采用NIO方式。
    package com.heyang.biz.server.test.nio;

    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintWriter;
    import java.net.Socket;
    import java.util.Scanner;



    public class TestClient{
        
    public static void main(String[] args) throws Exception{
            Socket s
    =new Socket("127.0.0.1",8888);
            
            InputStream  inStram
    =s.getInputStream();
            OutputStream outStream
    =s.getOutputStream();
            
            
    // 輸出
            PrintWriter out=new PrintWriter(outStream,true);
            
            out.print(
    "getPublicKey你好!");
            out.flush();

            s.shutdownOutput();
    // 輸出結束
            
            
    // 輸入
            Scanner in=new Scanner(inStram);
            StringBuilder sb
    =new StringBuilder();
            
    while(in.hasNextLine()){
                String line
    =in.nextLine();
                sb.append(line);
            }
            String response
    =sb.toString();
            System.out.println(
    "response="+response);
        }
    }

    服務器端的輸出:
    .
    接收到信息:getPublicKey你好!
    .

    客戶端的輸出:
    response=你好,客戶端. 已經收到你的信息getPublicKey你好!
    posted on 2011-01-03 14:36 何楊 閱讀(4715) 評論(0)  編輯  收藏

    只有注冊用戶登錄后才能發表評論。


    網站導航:
     
    主站蜘蛛池模板: 国产亚洲日韩一区二区三区| 亚洲gv白嫩小受在线观看| 18国产精品白浆在线观看免费| 国产精品久久永久免费| 久久精品7亚洲午夜a| 18gay台湾男同亚洲男同| 亚洲av无码一区二区三区人妖 | 亚洲成人午夜在线| 水蜜桃视频在线观看免费播放高清| 99爱视频99爱在线观看免费| 国产精品另类激情久久久免费| 亚洲成A人片在线观看无码不卡| 亚洲人成人无码.www石榴| 黄视频在线观看免费| 一二三四视频在线观看中文版免费| 国产亚洲精久久久久久无码77777| www成人免费视频| 国产精品成人免费一区二区| 亚洲Av永久无码精品三区在线| 成全高清在线观看免费| 亚洲乱码国产一区网址| 亚洲日韩av无码中文| 免费人成年激情视频在线观看 | 免费看美女被靠到爽| 亚洲国产美女精品久久久久∴| 亚洲av午夜电影在线观看| 国产男女猛烈无遮挡免费视频网站| 男女男精品网站免费观看| 日产乱码一卡二卡三免费| 亚洲黄色中文字幕| 成全影视免费观看大全二| 亚洲第一网站免费视频| 在线播放免费人成毛片乱码| 亚洲综合网美国十次| 香蕉高清免费永久在线视频| 一个人看的www免费在线视频| 久久久久久亚洲精品成人| 2019中文字幕免费电影在线播放| 久久精品国产亚洲av成人| 欧美a级在线现免费观看| 久久99精品免费一区二区|