99热在线精品一区二区三区_国产伦精品一区二区三区女破破_亚洲一区二区三区无码_精品国产欧美日韩另类一区

public class MyServer {
  private static ExecutorService executorService = Executors.newCachedThreadPool();  //創(chuàng)建一個(gè)線(xiàn)程池
  private static class HandleMsg implements Runnable{   //一旦有新的客戶(hù)端請(qǐng)求，創(chuàng)建這個(gè)線(xiàn)程進(jìn)行處理
  Socket client;   //創(chuàng)建一個(gè)客戶(hù)端
  public HandleMsg(Socket client){  //構(gòu)造傳參綁定
   this.client = client;
  }
  @Override
  public void run() {
   BufferedReader bufferedReader = null;  //創(chuàng)建字符緩存輸入流
   PrintWriter printWriter = null;   //創(chuàng)建字符寫(xiě)入流
   try {
    bufferedReader = new BufferedReader(new InputStreamReader(client.getInputStream()));  //獲取客戶(hù)端的輸入流
    printWriter = new PrintWriter(client.getOutputStream(),true);   //獲取客戶(hù)端的輸出流，true是隨時(shí)刷新
    String inputLine = null;
    long a = System.currentTimeMillis();
    while ((inputLine = bufferedReader.readLine())!=null){
     printWriter.println(inputLine);
    }
    long b = System.currentTimeMillis();
    System.out.println("此線(xiàn)程花費(fèi)了："+(b-a)+"秒！");
   } catch (IOException e) {
    e.printStackTrace();
   }finally {
    try {
     bufferedReader.close();
     printWriter.close();
     client.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
   }
  }
 }
 public static void main(String[] args) throws IOException {   //服務(wù)端的主線(xiàn)程是用來(lái)循環(huán)監(jiān)聽(tīng)客戶(hù)端請(qǐng)求
  ServerSocket server = new ServerSocket(8686);  //創(chuàng)建一個(gè)服務(wù)端且端口為8686
  Socket client = null;
  while (true){   //循環(huán)監(jiān)聽(tīng)
   client = server.accept();  //服務(wù)端監(jiān)聽(tīng)到一個(gè)客戶(hù)端請(qǐng)求
   System.out.println(client.getRemoteSocketAddress()+"地址的客戶(hù)端連接成功!");
   executorService.submit(new HandleMsg(client));  //將該客戶(hù)端請(qǐng)求通過(guò)線(xiàn)程池放入HandlMsg線(xiàn)程中進(jìn)行處理
  }
 }
}

public class MyClient {
 public static void main(String[] args) throws IOException {
  Socket client = null;
  PrintWriter printWriter = null;
  BufferedReader bufferedReader = null;
  try {
   client = new Socket();
   client.connect(new InetSocketAddress("localhost",8686));
   printWriter = new PrintWriter(client.getOutputStream(),true);
   printWriter.println("hello");
   printWriter.flush();
   bufferedReader = new BufferedReader(new InputStreamReader(client.getInputStream()));   //讀取服務(wù)器返回的信息并進(jìn)行輸出
   System.out.println("來(lái)自服務(wù)器的信息是："+bufferedReader.readLine());
  } catch (IOException e) {
   e.printStackTrace();
  }finally {
   printWriter.close();
   bufferedReader.close();
   client.close();
  }
 }
}

ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

1).數(shù)據(jù)從Channel到Buffer：channel.read(byteBuffer);
2).數(shù)據(jù)從Client到Buffer：byteBuffer.put(...);

1).數(shù)據(jù)從Buffer到Channel：channel.write(byteBuffer);
2).數(shù)據(jù)從Buffer到Server：byteBuffer.get(...);

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

serverSocketChannel.close();

while(true){
 SocketChannel socketChannel = serverSocketChannel.accept();
 clientChannel.configureBlocking(false);
}

SocketChannel clientChannel = SocketChannel.open();
clientChannel.configureBlocking(false);
clientChannel.connect(new InetSocketAddress(port));
clientChannel.register(selector, SelectionKey.OP_CONNECT);

selectionKey.isAcceptable();
selectionKey.isConnectable();
selectionKey.isReadable();
selectionKey.isWritable();

Channel channel = selectionKey.channel();
Selector selector = selectionKey.selector();

clientChannel.register(key.selector(), SelectionKey.OP_READ,ByteBuffer.allocateDirect(1024));

selectionKey.attach(Object);
Object anthorObj = selectionKey.attachment();

package cn.blog.test.NioTest;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.*;
import java.nio.charset.Charset;
import java.util.Iterator;
import java.util.Set;
public class MyNioServer {
 private Selector selector;   //創(chuàng)建一個(gè)選擇器
 private final static int port = 8686;
 private final static int BUF_SIZE = 10240;
 private void initServer() throws IOException {
  //創(chuàng)建通道管理器對(duì)象selector
  this.selector=Selector.open();
  //創(chuàng)建一個(gè)通道對(duì)象channel
  ServerSocketChannel channel = ServerSocketChannel.open();
  channel.configureBlocking(false);  //將通道設(shè)置為非阻塞
  channel.socket().bind(new InetSocketAddress(port));  //將通道綁定在8686端口
  //將上述的通道管理器和通道綁定，并為該通道注冊(cè)O(shè)P_ACCEPT事件
  //注冊(cè)事件后，當(dāng)該事件到達(dá)時(shí)，selector.select()會(huì)返回（一個(gè)key），如果該事件沒(méi)到達(dá)selector.select()會(huì)一直阻塞
  SelectionKey selectionKey = channel.register(selector,SelectionKey.OP_ACCEPT);
  while (true){  //輪詢(xún)
   selector.select();   //這是一個(gè)阻塞方法，一直等待直到有數(shù)據(jù)可讀，返回值是key的數(shù)量（可以有多個(gè)）
   Set keys = selector.selectedKeys();   //如果channel有數(shù)據(jù)了，將生成的key訪(fǎng)入keys集合中
   Iterator iterator = keys.iterator();  //得到這個(gè)keys集合的迭代器
   while (iterator.hasNext()){    //使用迭代器遍歷集合
    SelectionKey key = (SelectionKey) iterator.next();  //得到集合中的一個(gè)key實(shí)例
    iterator.remove();   //拿到當(dāng)前key實(shí)例之后記得在迭代器中將這個(gè)元素刪除，非常重要，否則會(huì)出錯(cuò)
    if (key.isAcceptable()){   //判斷當(dāng)前key所代表的channel是否在Acceptable狀態(tài)，如果是就進(jìn)行接收
     doAccept(key);
    }else if (key.isReadable()){
     doRead(key);
    }else if (key.isWritable() && key.isValid()){
     doWrite(key);
    }else if (key.isConnectable()){
     System.out.println("連接成功！");
    }
   }
  }
 }
 public void doAccept(SelectionKey key) throws IOException {
  ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();
  System.out.println("ServerSocketChannel正在循環(huán)監(jiān)聽(tīng)");
  SocketChannel clientChannel = serverChannel.accept();
  clientChannel.configureBlocking(false);
  clientChannel.register(key.selector(),SelectionKey.OP_READ);
 }
 public void doRead(SelectionKey key) throws IOException {
  SocketChannel clientChannel = (SocketChannel) key.channel();
  ByteBuffer byteBuffer = ByteBuffer.allocate(BUF_SIZE);
  long bytesRead = clientChannel.read(byteBuffer);
  while (bytesRead>0){
   byteBuffer.flip();
   byte[] data = byteBuffer.array();
   String info = new String(data).trim();
   System.out.println("從客戶(hù)端發(fā)送過(guò)來(lái)的消息是："+info);
   byteBuffer.clear();
   bytesRead = clientChannel.read(byteBuffer);
  }
  if (bytesRead==-1){
   clientChannel.close();
  }
 }
 public void doWrite(SelectionKey key) throws IOException {
  ByteBuffer byteBuffer = ByteBuffer.allocate(BUF_SIZE);
  byteBuffer.flip();
  SocketChannel clientChannel = (SocketChannel) key.channel();
  while (byteBuffer.hasRemaining()){
   clientChannel.write(byteBuffer);
  }
  byteBuffer.compact();
 }
 public static void main(String[] args) throws IOException {
  MyNioServer myNioServer = new MyNioServer();
  myNioServer.initServer();
 }
}

package cn.blog.test.NioTest;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
public class MyNioClient {
 private Selector selector;   //創(chuàng)建一個(gè)選擇器
 private final static int port = 8686;
 private final static int BUF_SIZE = 10240;
 private static ByteBuffer byteBuffer = ByteBuffer.allocate(BUF_SIZE);
 private void initClient() throws IOException {
  this.selector = Selector.open();
  SocketChannel clientChannel = SocketChannel.open();
  clientChannel.configureBlocking(false);
  clientChannel.connect(new InetSocketAddress(port));
  clientChannel.register(selector, SelectionKey.OP_CONNECT);
  while (true){
   selector.select();
   Iterator iterator = selector.selectedKeys().iterator();
   while (iterator.hasNext()){
    SelectionKey key = iterator.next();
    iterator.remove();
    if (key.isConnectable()){
     doConnect(key);
    }else if (key.isReadable()){
     doRead(key);
    }
   }
  }
 }
 public void doConnect(SelectionKey key) throws IOException {
  SocketChannel clientChannel = (SocketChannel) key.channel();
  if (clientChannel.isConnectionPending()){
   clientChannel.finishConnect();
  }
  clientChannel.configureBlocking(false);
  String info = "服務(wù)端你好!!";
  byteBuffer.clear();
  byteBuffer.put(info.getBytes("UTF-8"));
  byteBuffer.flip();
  clientChannel.write(byteBuffer);
  //clientChannel.register(key.selector(),SelectionKey.OP_READ);
  clientChannel.close();
 }
 public void doRead(SelectionKey key) throws IOException {
  SocketChannel clientChannel = (SocketChannel) key.channel();
  clientChannel.read(byteBuffer);
  byte[] data = byteBuffer.array();
  String msg = new String(data).trim();
  System.out.println("服務(wù)端發(fā)送消息："+msg);
  clientChannel.close();
  key.selector().close();
 }
 public static void main(String[] args) throws IOException {
  MyNioClient myNioClient = new MyNioClient();
  myNioClient.initClient();
 }
}