// 文件名：moreServer.java
import java.io.*;
import java.net.*;
import java.util.*;
/**
* <p>Title: 多線程服務器</p>
* <p>Description: 本實例使用多線程實現多服務功能。</p>
* <p>Copyright: Copyright (c) 2003</p>
* <p>Filename: </p>
* @version 1.0
*/
class moreServer
{
public static void main (String [] args) throws IOException
{
System.out.println ("Server starting...\n");
//使用8000端口提供服務
ServerSocket server = new ServerSocket (8000);
while (true)
{
//阻塞，直到有客戶連接
Socket sk = server.accept ();
System.out.println ("Accepting Connection...\n");
//啟動服務線程
new ServerThread (sk).start ();
}
}
}
//使用線程，為多個客戶端服務
class ServerThread extends Thread
{
private Socket sk;
ServerThread (Socket sk)
{
this.sk = sk;
}
//線程運行實體
public void run ()
{
BufferedReader in = null;
PrintWriter out = null;
try{
InputStreamReader isr;
isr = new InputStreamReader (sk.getInputStream ());
in = new BufferedReader (isr);
out = new PrintWriter (
new BufferedWriter(
new OutputStreamWriter(
sk.getOutputStream ())), true);
while(true){
//接收來自客戶端的請求，根據不同的命令返回不同的信息。
String cmd = in.readLine ();
System.out.println(cmd);
if (cmd == null)
break;
cmd = cmd.toUpperCase ();
if (cmd.startsWith ("BYE")){
out.println ("BYE");
break;
}else{
out.println ("你好，我是服務器！");
}
}
}catch (IOException e)
{
System.out.println (e.toString ());
}
finally
{
System.out.println ("Closing Connection...\n");
//最後釋放資源
try{
if (in != null)
in.close ();
if (out != null)
out.close ();
if (sk != null)
sk.close ();
}
catch (IOException e)
{
System.out.println("close err"+e);
}
}
}
}
//文件名：SocketClient.java
import java.io.*;
import java.net.*;
class SocketThreadClient extends Thread
{
public static int count = 0;
//構造器，實現服務
public SocketThreadClient (InetAddress addr)
{
count++;
BufferedReader in = null;
PrintWriter out = null;
Socket sk = null;
try{
//使用8000端口
sk = new Socket (addr, 8000);
InputStreamReader isr;
isr = new InputStreamReader (sk.getInputStream ());
in = new BufferedReader (isr);
//建立輸出
out = new PrintWriter (
new BufferedWriter(
new OutputStreamWriter(
sk.getOutputStream ())), true);
//向服務器發送請求
System.out.println("count:"+count);
out.println ("Hello");
System.out.println (in.readLine ());
out.println ("BYE");
System.out.println (in.readLine ());
}
catch (IOException e)
{
System.out.println (e.toString ());
}
finally
{
out.println("END");
//釋放資源
try
{
if (in != null)
in.close ();
if (out != null)
out.close ();
if (sk != null)
sk.close ();
}
catch (IOException e)
{
}
}
}
}
//客戶端
public class SocketClient{
public static void main(String[] args) throws IOException,InterruptedException
{
InetAddress addr = InetAddress.getByName(null);
for(int i=0;i<10;i++)
new SocketThreadClient(addr);
Thread.currentThread().sleep(1000);
}
}
