快捷導(dǎo)航

java搭建一個Socket服務(wù)器響應(yīng)多用戶訪問

更新時間：2017年02月14日 08:44:43 作者：沈君

本篇文章主要介紹了java搭建一個Socket服務(wù)器響應(yīng)多用戶訪問，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

當(dāng)我們搭建了一個Socket服務(wù)端，是需要去響應(yīng)多用戶的訪問的。此時，我們就要使用多線程，為每個訪問的用戶建立一個線程來響應(yīng)該用戶的訪問。

具體實現(xiàn)，看如下代碼：

package com.sun.socket; 
import Java.io.IOException; 
import java.NET.*; 
import java.io.*; 
import java.util.*;

/** 
* Description: 
* 搭建一個Socket服務(wù)器響應(yīng)多用戶訪問 
* @author Lee 
* */ 
public class ServerSocketDemo { 
ArrayList MSG = new ArrayList<>(); 
ArrayList RES = new ArrayList<>();

/**
 * Description:
 * 初始化數(shù)據(jù)
 * */
public void init(){
  MSG.add("hellow");
  RES.add("hi");
}

/**
 * Description:
 * 搭建一個Socket服務(wù)器響應(yīng)多個用戶訪問
 * */
public void test1(){
  init();
  ServerSocket server = null;

  try{
    //以指定端口搭建一個Socket服務(wù)端
    server = new ServerSocket(12000);  

    //等待客戶端Socket實例，并創(chuàng)建一個線程去響應(yīng)該客戶單實例
    while(true){
      new Response(server.accept()).start();;
    }

  }catch(IOException e){
    e.printStackTrace();
  }finally{
    try{
      server.close();
    }catch(IOException e){
      e.printStackTrace();
    }

  }
}

/**
 * Description:
 * 根據(jù)用戶輸入的內(nèi)容，返回相應(yīng)的內(nèi)容
 * 
 * @param msg 客戶端輸入的內(nèi)容
 * @return 返回服務(wù)端回復(fù)的內(nèi)容
 * */
public String getMsg(String msg){
  String res = "Are you kidding me?Please speak English.";

  for(int i=1;i<MSG.size();i++){
    if(msg.contains(MSG.get(i))){
      res = RES.get(i);
    }
  }

  return res;
}


public static void main(String[] args) {
  // TODO Auto-generated method stub
  new ServerSocketDemo().test1();
}

/**
 * Description:
 * 響應(yīng)用戶
 * @author Lee
 * */
class Response extends Thread{
  Socket client;

  /**
   * Description:
   * 默認(rèn)構(gòu)造器 
   * */
  public Response(){}
  /**
   * Description:
   * 初始化Socket
   * */
  public Response(Socket client){
    this.client = client;
  }

  @Override
  public void run(){
    Scanner input = null;
    PrintWriter output = null;

    try{
      //獲取用戶端的輸入和輸出流
      input = new Scanner(client.getInputStream());
      output = new PrintWriter(client.getOutputStream());

      output.println("歡迎訪問!");
      output.flush();

      //等待客戶端的輸入
      String content = null;
      while(input.hasNext()){
        content = input.nextLine();

        //根據(jù)用戶端的輸入，做出相應(yīng)的反應(yīng)
        if(content.equalsIgnoreCase("quit")){
          break;
        }else{
          output.println(getMsg(content));
          output.flush();
        }
      }

    }catch(IOException e){
      e.printStackTrace();
    }finally{
      //關(guān)閉資源
      input.close();
      output.close();
    }


  }
}
}

1、我們可以寫一個小小測試工具類，來測試一下public String getMsg(String msg)方法。

對該類右鍵，選擇new新建一個JUnit Test Case 。

package com.sun.socket;
import org.junit.Assert;
import org.junit.Test;
public class ServerSocketDemoTest {
  @Test
  public void testGetMsg() {
    try{
      //調(diào)用該方法，并與其目標(biāo)值進(jìn)行對比。
      String msg = new ServerSocketDemo().getMsg("在嗎");
      Assert.assertEquals("gun!", msg);

    }catch(Exception e){
      e.printStackTrace();
    }
  }

}

2、使用apche JMeter工具對該服務(wù)端進(jìn)行壓力測試

（1）打開Apache JMeter，右鍵測試計劃->添加->Threads（Users）->Setup Thread Group

這里寫圖片描述