多线程服务器的改造

多线程服务器的改造
测试方法：在命令行里输入 telnet localhost 9090
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.*;
public class ServerThread extends Thread{

private Socket Client;//线程对象要处理的连接变量
private OutputStream out;//输出流对象

// 创建这个线程对象时，传入一个他要处理的连接对象
public ServerThread(Socket sc)
{
  this.Client=sc;
}

//将发送的消息代码包装到一个方法中
public void sendMsg2Me(String msg)
{
byte[] data=msg.getBytes();//从字符串得到一个字节数组
try {
out.write(data);//用输出对象发送
out.flush();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

public void run()
{
//在RUN中调用处理连接的方法
processChat(this.Client);
//处理方法执行完毕后，线程自己退出

}


//处理客户端进入的连接对象
private void processChat(Socket client)
{
try
{
out=client.getOutputStream();//得到一个输出/输入的流对象
InputStream ins=client.getInputStream();
String s="你好，欢迎来到服务器\r\n";
this.sendMsg2Me(s);//发送信息
String inputS=readString(ins);//读取客户端发来的

while(!inputS.equals("bye"))
{
s="我收到了你说的话"+inputS+"\r\n";
this.sendMsg2Me(s);//将这个字符串发送给客户端对象
inputS=readString(ins);//再次读取

}
s="你好，欢迎再来！\r\n";
this.sendMsg2Me(s);
client.close();

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

/**
* 输入流对象中读取字节，拼成一个字符串返回
* 如何读取到一个字节为13，则认为以前的是一个字符串
* ins输入流对象
* return：从流上（客户端发来的）读到的字符串
* @param ins
* @return
* @throws IOException
*/
private String readString(InputStream ins) throws IOException
{
StringBuffer stb=new StringBuffer();//创建一个字符串缓冲区
char c=0;
while(c!=13)//13是回车的ASC码
{//遇到一个换行就是一句话
int i=ins.read();//读取客户端发来的一个字节
c=(char)i;//将输入的字节转换为一个char
stb.append(c);
}
//把读到的字节组转换为字符串
String inputS=stb.toString().trim();
return inputS;

}



public static void main(String[] args) {

/**
* 在指定端口上启动一个服务器
* @param prot：服务器所有的端口
*/

// public void setUpServer(int port)
// {
try
{
//1.建立绑定在指定端口上的服务器对象
ServerSocket server=new ServerSocket(9090);
while(true)//让服务器进入循环等待状态
{
Socket client=server.accept();
//创建了一个线程对象时传入进入的连接
ServerThread st=new ServerThread(client);
st.start();//启动这个线程去处理连接
System.out.println("已启动一个线程去处理这个连接对象了");
}
}catch(Exception e)
{
e.printStackTrace();
}
// }
}

}