Java 多线程ServerSocket通讯简单实例(基于TCP协议)

浏览数：23 / 时间：2015年06月08日

首先是建立一个类继承Thread类

package com.zzq.socket;
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;

public class ServerThread extends Thread{
 Socket socket = null;

 /**
  * 每个线程共享当前socket
  * @param socket
  */
 public ServerThread(Socket socket){
  this.socket = socket;
 }
 @Override
 public void run() {
  //获取输入流 读取客户端信息
  InputStream is = null;
  InputStreamReader isr = null;
  BufferedReader br = null;
  //获取输出流 发送给客户端
  OutputStream os = null;
  PrintWriter pw = null;
  try {
   is = socket.getInputStream();
   isr = new InputStreamReader(is);
   br = new BufferedReader(isr);
   String info = null;
   while((info = br.readLine())!=null){
    System.out.println("服务器 client:"+info);
   }
   socket.shutdownInput();
   os = socket.getOutputStream();
   //向客户端发送信息
   pw = new PrintWriter(os);
   pw.write("200");
   pw.flush();
  } catch (IOException e) {
   e.printStackTrace();
  }finally{
   //关闭资源
   try {
    if(os!=null)
     os.close();
    if(pw!=null)
     pw.close();
    if(br!=null)
     br.close();
    if(isr!=null)
     isr.close();
    if(is!=null)
     is.close();
    if(socket!=null)
        socket.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
 }
}

然后写服务端代码

package com.zzq.socket;
import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
public class TCPServerSocket {
 public static void main(String[] args) {
  try {
   //建立服务端socket 监听8888端口
   ServerSocket serverSocket = new ServerSocket(8888);
   Socket socket = null;
   int count = 0;
   //循环获取客户端连接
   while(true){
    socket = serverSocket.accept();
    //客户端连接 就使用 ServerThread线程 去处理socket读取和输入
    ServerThread serverThread = new ServerThread(socket);
    serverThread.start();
    count++;
    System.out.println("客户端连接数量--("+count+")");
    InetAddress address = socket.getInetAddress();
    System.out.println("客户端Ip "+address.getHostAddress());
   }
  } catch (IOException e) {
   e.printStackTrace();
  }
  
 }
}

接下去是客户端

package com.zzq.socket;
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;
public class Client {
 public static void main(String[] args) {
  try {
   //创建客户端套接字 指定服务器地址与端口
   Socket socket = new Socket("localhost",8888);
   OutputStream os = socket.getOutputStream();
   PrintWriter pw = new PrintWriter(os);
   pw.write("username:root password:123");
   pw.flush();
   socket.shutdownOutput();
   InputStream is = socket.getInputStream();
   BufferedReader br = new BufferedReader(new InputStreamReader(is));
   String info = null;
   while((info = br.readLine())!=null){
    System.out.println("服务器 client:"+info);
   }
   //关闭资源
   br.close();
   is.close();
   pw.close();
   os.close();
   socket.close();
  } catch (UnknownHostException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  
 }
}