Java实例开发05-01 简单的多线程服务器

知识点：
1.Socket编程：ServerSocket类 Socket类
2.Java多线程：编程原则（能够独立在一个线程中完成的操作就应该开辟一个新的线程）
3.telnet命令

[注]win7是有telnet功能的，只是默认没有开启，开启方法：
打开“控制面板”，找到程序和功能，然后点击左上方的“打开或关闭windows功能”，会弹出windows功能的对话框，这个对话框里面有许多windows的小功能，再找到TelentClient，打上勾，确认即可.

源代码：
/**
* @Author：胡家威
* @CreateTime：2011-9-20 下午08:30:28
* @Description：
*/

package com.yinger.chap51;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;

public class ReceiveServer {

final int PORT=9090;

public static void main(String[] args) {
new ReceiveServer();
}

public ReceiveServer(){
ServerSocket serverSocket = null;
Socket socket = null;
ServerThread serverThread = null;
try {
serverSocket = new ServerSocket(PORT);
System.out.println("Server is start!\t"+new Date());
System.out.println("port:"+serverSocket.getLocalPort());
System.out.println("timeout:"+serverSocket.getSoTimeout());
while(true){
socket = serverSocket.accept();
serverThread = new ServerThread(socket);
serverThread.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}

}

class ServerThread extends Thread{
Socket socket;
BufferedReader br;
PrintWriter pw;

public ServerThread(Socket socket) {
this.socket = socket;
try {
// 对socket的输入输出流进行封装
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);//true
pw.println("Welcom to server!\t"+new Date());
pw.println("LocalPort:"+socket.getLocalPort());
pw.println("Port:"+socket.getPort());
pw.println("what can I do for you?");
} catch (IOException e) {
e.printStackTrace();
}
}

@Override
public void run() {
String command;
while(true){
try {
command= br.readLine();
if(command==null || command.trim().equalsIgnoreCase("exit")){
break;
}else if(command.trim().equalsIgnoreCase("help")){
pw.println("HELP\tQUERY\tEXIT");
}else if(command.trim().equalsIgnoreCase("query")){
pw.println("I don't know!");
}else{
pw.println("command is not found!Please see HELP!");
}
} catch (IOException e) {
e.printStackTrace();
}
}
try {
socket.close();//关闭连接！
} catch (IOException e) {
e.printStackTrace();
}
}

}

效果展示：

服务器启动：



建立连接：



测试：



通过 Wiz 发布