Java网络编程之TCP程序设计

package pack01;

import java.io.*;
import java.net.*;
import org.junit.Test;

public class TestNet1 {
 
 @Test //***********************客户端测试方法***********************
 public void client() {
  
  Socket socket = null; //建立客户端网络套接字
  OutputStream socket_os = null; //客户端输出流
  
  try {
   //1.获取本机环路地址
   InetAddress inet = InetAddress.getByName("127.0.0.1");
   
   //2.创建Socket对象
   socket = new Socket(inet, 10000);
   
   //3.获取输出流
   socket_os = socket.getOutputStream();
   
   //4.客户端输出信息
   socket_os.write( "客户端发送信息".getBytes() );
   
  } catch (IOException e) {
   e.printStackTrace();
   
  } finally {
   
   try { //关闭输出流
    socket_os.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
   
   try { //关闭客户端套接字
    socket.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
 }
 
 @Test //***********************服务端测试方法***********************
 public void server() {
  
  ServerSocket serSocket = null;
  Socket socket = null;
  InputStream socket_is = null;
  
  try {
   serSocket = new ServerSocket(10000);
   socket = serSocket.accept(); //获取服务端套接字
   socket_is = socket.getInputStream(); //获取输入流
   
   byte[] b = new byte[100]; //用于接收信息的字节数组
   int len;
   StringBuffer sb = new StringBuffer();
   
   while( (len = socket_is.read(b)) != -1 ) {
    sb.append( new String(b,0,len) ); //将字节信息连续保存在buffer数组里
   }
   System.out.println("来自" + socket.getInetAddress().getHostName() + "的信息：");
   System.out.println( sb );
   
  } catch (IOException e) {
   e.printStackTrace();
   
  } finally {
   
   try { //关闭输入流
    socket_is.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
   
   try { //关闭Socket对象
    socket.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
   
   try { //关闭ServerSocket对象
    serSocket.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
 }

}