java Socket 多线程

先上代码，代码里有注释，自己看看去吧，不懂的给我留言。



ps: 注意一下客户端和服务端的 in 和 out 的实例化顺序。

     在 web.xml 添加一个servlet可以让线程随着项目的启动而启动。



/**************** web.xml begin **************/

 <servlet>
  <servlet-name>socketManager</servlet-name>
  <servlet-class>com.net.jnjc.core.ScoketManager</servlet-class>
  <load-on-startup>2</load-on-startup>
 </servlet>
 <servlet-mapping>
  <servlet-name>socketManager</servlet-name>
  <url-pattern>/Sock</url-pattern>
 </servlet-mapping>

/*****************  web.xml end ***************/



/**************** SocketManager  begin *****************/

package com.net.jnjc.core;


import javax.servlet.http.HttpServlet;

import org.apache.log4j.LogManager;

import org.apache.log4j.Logger;

import com.net.jnjc.util.SocketThread;

/**
 * 继承了HttpServlet对象，重写了init()方法，项目运行时即可调用到重写的init()方法
 * @author qin
 *
 */
@SuppressWarnings("serial")
public class ScoketManager extends HttpServlet {

 //log4j对象
 Logger log = LogManager.getLogger(ScoketManager.class);

 @Override
 public void init() {
  //记录监听服务的运行
  log.fatal("socketServer started success....");
  try {
   /*
    这里就像在火车站买票，一个监听对象就相当于一个售票窗口，
    客户端请求就相当于买票的人，
    若只有一个售票窗口，买票的人多了，就要排队。
    实例一个监听对象就相当于开一个售票窗口。
    按需求和服务器性能，看自己要开多少个监听对象
    */
   
   /*
    //开多个监听对象
    for(int i = 0;i< 5;i++){
     //实例一个监听器
    new SocketThread().start();
    } 
    */
   
   //实例一个监听器
   new SocketThread().start();
  } catch (Exception ex) {
   //记录异常信息
   log.error(ex.getMessage());
   ex.printStackTrace();
  }
 }
}

/************************  SocketManager end ***************/



这个是服务端，按照职能来说，是等候服务的请求再反馈结果。

所以先实例化 in 来获取客户端请求，再实例化 out 反馈服务端的

处理结果。

/**************** SocketThread  begin ***********/

package com.net.jnjc.util;

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;
import java.text.SimpleDateFormat;
import java.util.Date;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;

/**
 * 服务端监听代码
 * 继承了Thread，重写run()方法即可实现新开线程运行，新开的线程
 * 运行的是重写的run()方法里面的内容。
 * 
 * @author qin
 *
 */
public class SocketThread extends Thread {

 public void run() {
  while (true) {
   //log4j 
   Logger log = LogManager.getLogger(SocketThread.class);
   //标识服务信息
   SimpleDateFormat sdf = new SimpleDateFormat(
     "yyyy-MM-dd HH:mm:ss.SSS");
   ServerSocket ss;//socket服务监听对象
   Socket socket;//获取监听得到的结果
   BufferedReader in;//输入流
   PrintWriter out;//输出流

   try {
    //设置监听的端口，并实例监听对象
    ss = new ServerSocket(10000);

    while (true) {
     
     //开始监听，若没有客户端请求则线程一直停留在这里等待请求，
     //一旦就有请求，就获取监听到的对象
     socket = ss.accept();
     
     InputStream sis = socket.getInputStream();// socket服务获取的输入流
     
     // 等待读取状态
     // 大于零为获取完毕
     while (sis.available() <= 0)
      System.out.println("inputStream is waitting...");
     
     
     in = new BufferedReader(new InputStreamReader(sis));// 获取输入
     
     String line = "";//监听到的字符串
     
     // 读数据
     while (in.ready()) {
      line += in.readLine();
     }

     //记录下获取到的字符串流
     log.warn("client request is :" + line);

     out = new PrintWriter(socket.getOutputStream(), true);// 构建输出
     
     // 输出
     out.println("server response " + sdf.format(new Date()));

     //关闭当前请求对象
     out.close();
     in.close();
     socket.close();
    }
   } catch (IOException e) {
    String msg = "\n" + e.getMessage();
    for (StackTraceElement ste : e.getStackTrace()) {
     msg += "\n" + ste.getClassName() + "-" + ste.getFileName()
       + "-" + ste.getMethodName() + "-"
       + ste.getLineNumber();
    }
    log.fatal(msg);
   } catch (Exception ex) {
    String msg = "\n" + ex.getMessage();
    for (StackTraceElement ste : ex.getStackTrace()) {
     msg += "\n" + ste.getClassName() + "-" + ste.getFileName()
       + "-" + ste.getMethodName() + "-"
       + ste.getLineNumber();
    }
    log.fatal(msg);
   }

  }
 }
}

/******************** SocketThread end *******************/





这里需要注意一下 in 和 out 的顺序，我们得按照程序的流程来看，

因为这个是客户端，所以这里得先输出再得到服务端的相应结果，

所以这里得先实例化输出对象再获取输入对象。

/**************** SocketClientUtil  begin **************/

package com.net.jnjc.util;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

/**
 * 客户端工具类
 * 发送socket信息
 * @author qin
 *
 */
public class SocketClientUtil {

 /**
  * 客户端
  * 调用服务端
  * @param host 服务端地址 
  * @param port 服务端端口
  * @param msg 发送给服务端的信息
  * @return 服务端的信息反馈
  * @throws Exception 发送socket过程中遇到的异常
  */
 public static String SocketClient(String host, int port, String msg)
   throws Exception {
  Socket socket = null;
  BufferedReader in = null;
  PrintWriter out = null;
  String str = "";
  socket = new Socket(host, port);
  out = new PrintWriter(socket.getOutputStream(), true);
  out.println(msg);
  while(socket.getInputStream().available()<=0);
  in = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
  while (in.ready())
   str += in.readLine();  
  out.close();
  in.close();
  socket.close();

  return str;

 }

}

/************************  SocketClientUtil end **********************/



这个是客户端测试调用的测试类，用的是 junit 来测试。

Test2    方法才是用作测试客户端的，不过，先得服务端运行起来才能用，不然会直接抛异常。

/********************** ThreadTest  Begin *************************/

package com.net.jnjc.unit;


import java.text.SimpleDateFormat;
import java.util.Date;

import org.junit.Test;

import com.net.jnjc.util.SocketClientUtil;
import com.net.jnjc.util.SocketRunnable;
import com.net.jnjc.util.SocketThread;

public class ThreadTest {

 @Test
 public void Test() {
  SocketThread thread = new SocketThread();
  thread.start();
 }

 @Test
 public void Test1() {
  SocketRunnable runnable = new SocketRunnable();
  Thread thread = new Thread(runnable);
  thread.start();

 }

 @Test
 public void Test2() {
  String str = "";
  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
  String msg = "client request " + sdf.format(new Date());
  try {
   str = SocketClientUtil.SocketClient("127.0.0.1", 10000, msg);
   System.out.println(str);
  } catch (Exception ex) {
   ex.printStackTrace();   
  }
  
 }

}

/*************************  ThreadTtest End *************************/