TCP应用程序

package tcp;

import java.io.*;import java.net.*;

public class TcpServer {

 /**  * @param args  */ public static void main(String[] args) {  TcpServer ts = new TcpServer();  //多线程的例子  ts.ThreadServer();//  单线程的例子.//  ts.easySocket(); }   public void easySocket (){  try {   ServerSocket ss = new ServerSocket(5000);   Socket s = ss.accept();   System.out.println("sssss");   InputStream is = s.getInputStream();   OutputStream os = s.getOutputStream();   String str = "大家好!这是server端的信息!";   os.write(str.getBytes());   //通过包装类,来实现一行一行的读取.不用自己写判断.   BufferedReader br = new BufferedReader(new InputStreamReader(is));   System.out.println(br.readLine());   /*只能读取一个字节,要么就自己写方法,判断是回车还是换行.   byte[] buf = new byte[1024];   int len = is.read(buf);   System.out.println(new String(buf,0,len));   is.close();   */   //关闭包装类的对象,就会自动的关闭底层类的对象.所以不需要写is.close()   br.close();   os.close();   s.close();   ss.close();     } catch (IOException e) {   e.printStackTrace();  } }  public void ThreadServer(){  try {   ServerSocket ss = new ServerSocket(3000);   while(true){    Socket s = ss.accept();    new Thread(new TransformSocket(s)).start();   }  } catch (IOException e) {   e.printStackTrace();  } }

}

 

 

 

 

 

package tcp;

import java.io.*;import java.net.Socket;

public class TransformSocket implements Runnable {

 private Socket s = null;  public TransformSocket(Socket s){  this.s = s; }   public void run() {  try {   InputStream is = s.getInputStream();   BufferedReader br = new BufferedReader(new InputStreamReader(is));   OutputStream os = s.getOutputStream();   PrintWriter pw = new PrintWriter(os,true);

//可以再while循环中做更多的事情.   while(true){    String readLine = br.readLine();    if(readLine.equals("quit")){     break;    }    System.out.println(readLine);    pw.println(readLine+"---!!!!!!");

   }   pw.close();   br.close();   s.close();     } catch (IOException e) {   e.printStackTrace();  } }

}