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

import org.junit.Test;
public class server {
	@Test
	 public void demo1() throws IOException{
	//创建一个端口号为8888的服务端socket
ServerSocket ss = new ServerSocket(8887);
//调用accept方法等待客户端连接
System.out.println("服务器准备启动");
Socket sock = ss.accept();
//获取输入流得到客户端的输入信息
InputStream is = sock.getInputStream();//获得字节流
InputStreamReader isr=new InputStreamReader(is);//将字节流转为字符流
BufferedReader br=new BufferedReader(isr);//为字符流提供缓冲
String s = br.readLine();
while(s!=null){
	System.out.println("客户端说"+s);
	s=br.readLine();
}
sock.shutdownInput();//可以不写
//服务端向客户端发数据
OutputStream os = sock.getOutputStream();
PrintWriter pw=new PrintWriter(os);
pw.write("我是赵瑾的服务端");
os.flush();
//关闭

//sock.shutdownOutput();
pw.close();
os.close();
br.close();
isr.close();
is.close();
ss.close();
sock.close();
	}
}

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

import org.junit.Test;

public class client {
	@Test
	public void demo1() throws UnknownHostException, IOException{
		//创建客户端socket，并指定端口号和地址
		Socket client = new Socket("localhost", 8887);
		//获得输出流向服务器发送数据
		OutputStream os = client.getOutputStream();//字节输出流
		PrintWriter pw=new PrintWriter(os);
		pw.write("我是赵瑾的客户端");
		pw.flush();//刷新缓存
		client.shutdownOutput();//可以不写
		//客户端接收服务端的数据
		InputStream is = client.getInputStream();
		InputStreamReader isr=new InputStreamReader(is);
		BufferedReader br=new BufferedReader(isr);
		String s = br.readLine();
		while(s!=null){
			System.out.println("服务端说"+s);
			s=br.readLine();
		}

		//关闭资源
		//client.shutdownInput();
		br.close();
		isr.close();
		is.close();
		pw.close();
		os.close();
		client.close();
	}
}