java搭建一个Socket服务器响应多用户访问

packagecom.sun.socket;

importJava.io.IOException;

importjava.NET.*;

importjava.io.*;

importjava.util.*;

/**

* Description:

* 搭建一个Socket服务器响应多用户访问

* @author Lee

* */

publicclassServerSocketDemo {

ArrayList MSG =newArrayList();

ArrayList RES =newArrayList();

/**

* Description:

* 初始化数据

* */

publicvoidinit(){

MSG.add("hellow");

RES.add("hi");

}

/**

* Description:

* 搭建一个Socket服务器响应多个用户访问

* */

publicvoidtest1(){

init();

ServerSocket server =null;

try{

//以指定端口搭建一个Socket服务端

server =newServerSocket(12000);

//等待客户端Socket实例，并创建一个线程去响应该客户单实例

while(true){

newResponse(server.accept()).start();;

}

}catch(IOException e){

e.printStackTrace();

}finally{

try{

server.close();

}catch(IOException e){

e.printStackTrace();

}

}

}

/**

* Description:

* 根据用户输入的内容，返回相应的内容

*

* @param msg 客户端输入的内容

* @return 返回服务端回复的内容

* */

publicString getMsg(String msg){

String res ="Are you kidding me?Please speak English.";

for(inti=1;i

if(msg.contains(MSG.get(i))){

res = RES.get(i);

}

}

returnres;

}

publicstaticvoidmain(String[] args) {

// TODO Auto-generated method stub

newServerSocketDemo().test1();

}

/**

* Description:

* 响应用户

* @author Lee

* */

classResponseextendsThread{

Socket client;

/**

* Description:

* 默认构造器

* */

publicResponse(){}

/**

* Description:

* 初始化Socket

* */

publicResponse(Socket client){

this.client = client;

}

@Override

publicvoidrun(){

Scanner input =null;

PrintWriter output =null;

try{

//获取用户端的输入和输出流

input =newScanner(client.getInputStream());

output =newPrintWriter(client.getOutputStream());

output.println("欢迎访问!");

output.flush();

//等待客户端的输入

String content =null;

while(input.hasNext()){

content = input.nextLine();

//根据用户端的输入，做出相应的反应

if(content.equalsIgnoreCase("quit")){

break;

}else{

output.println(getMsg(content));

output.flush();

}

}

}catch(IOException e){

e.printStackTrace();

}finally{

//关闭资源

input.close();

output.close();

}

}

}

}

packagecom.sun.socket;

importorg.junit.Assert;

importorg.junit.Test;

publicclassServerSocketDemoTest {

@Test

publicvoidtestGetMsg() {

try{

//调用该方法，并与其目标值进行对比。

String msg =newServerSocketDemo().getMsg("在吗");

Assert.assertEquals("gun!", msg);

}catch(Exception e){

e.printStackTrace();

}

}

}