java TCP

package com.client;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

/**
 * 客户端
 * @author ex_yixb
 *
 */
public class ClientServer {
	public static void main(String[] args) {
		Socket socket =null;
		try {
			InetAddress address = InetAddress.getByName("127.0.0.1");
			socket= new Socket(address,6000);
/*			socket.connect( new InetSocketAddress(address,6000), 30000 );   
			socket.setSendBufferSize(100);
*/			BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			Ththth thread=new Ththth(socket.getOutputStream());
			thread.start();
			Readss  readss = new Readss(socket.getInputStream());
			readss.start();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			
		}
	}
}

class Ththth extends Thread{
	  OutputStream output  = null;
	  
	  public Ththth(OutputStream outputStream) {
		  this.output=outputStream;
	}
	  public Ththth() {
	}
	  
	  public void run(){
		  try {
			  BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
			  PrintWriter out = new PrintWriter(output);
			//  out.println("QQ");
			//  out.flush();
			  while(true){
				  String str=bufferedReader.readLine();
				  System.out.println("发送："+str);
				  out.println(str);
				  out.flush();
			  }
		} catch (Exception e) {
			e.printStackTrace();
		}
	  }
}
class Readss extends Thread{
	  InputStream in  = null;
	  
	  public Readss(InputStream in) {
		  this.in=in;
	  }
	  public Readss() {
	  }
	  
	  public void run(){
		  try {
			  BufferedReader reader = new BufferedReader(new InputStreamReader(in));
			  while(true){
				  String str=reader.readLine();
				  System.out.println("客户端："+str);
			  }
		} catch (Exception e) {
			e.printStackTrace();
		}
	  }
}

package com.server;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服务器
 * @author ex_yixb
 *
 */
public class Server {
	
	
	public static void main(String[] args) {
		ServerSocket serverSocket=null;
		Socket socket=null;
		try {
			try {
				serverSocket= new ServerSocket(6000);
				System.out.println("开始监听");
				socket=serverSocket.accept();
				System.out.println("监听成功");
				InputStream inputStream = socket.getInputStream();
				BufferedReader read = new BufferedReader(new InputStreamReader(inputStream));
				PrintWriter out =new PrintWriter(socket.getOutputStream());				
					while(true){
						String str=read.readLine();
						System.out.println("服务器："+str);
						if(str!=null){
							out.println("服务器发送："+str);
							out.flush();
						}
						Thread.sleep(1000);
					}
			} catch (Exception e) {
				e.printStackTrace();
			}finally{
				try {
					socket.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			try {
				serverSocket.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		
	}
}