package com.gc.nio.tcp.socket;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

public class NioClient {
   public static void main(String[] args) {
	 for(int i=0;i<2;i++){
		new Thread(new Runnable(){

			@Override
			public void run() {
			   //打开客户端通道
				try {
					SocketChannel channel=SocketChannel.open();
					   channel.connect(new InetSocketAddress("192.168.155.1",8879));
					ByteArrayOutputStream baos=new ByteArrayOutputStream();
					ByteBuffer buff=ByteBuffer.allocate(1024);
			       //写数据
					 String str="我是客户端，我来访问你了"+Thread.currentThread().getId();
					 buff.put(str.getBytes());
					 buff.flip();
					 channel.write(buff);
					 channel.shutdownOutput();
					//读数据
					 int len=0;
					while(true){
						buff.clear();
					    len=channel.read(buff);
						if(len==-1)break;
						buff.flip();
						while(buff.hasRemaining()){
						baos.write(buff.get());
						}
						
					}
					System.out.println("来自服务器的消息："+new String(baos.toByteArray()));
					channel.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					System.out.println("服务器未启动");
					e.printStackTrace();
				}
				
				
			}
			 
		 }).start();
		
		 
		 
	 } 
       
   }
	
}