如何开发一个SocketServer-Client模型的程序

　　 开发原理：

　　 服务器，使用ServerSocket监听指定的端口，端口可以随意指定（由于1024以下的端口通常属于保留端口，在一些操作系统中不可以随意使用，所以建议使用大于1024的端口），等待客户连接请求，客户连接后，会话产生；在完成会话后，关闭连接。

　　 客户端，使用Socket对网络上某一个服务器的某一个端口发出连接请求，一旦连接成功，打开会话；会话完成后，关闭Socket。客户端不需要指定打开的端口，通常临时的、动态的分配一个1024以上的端口。

　　 ｛建立服务器｝

package org.tx;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.BufferedReader;
import java.io.InputStreamReader;

public class socketServer
{
ArrayList clientList = new ArrayList();

public static void main(String[] args)
{
//在main函数中，启动服务器的socket
new socketServer().OpenServer();

}

public void OpenServer()//启动socketServer
{
try
{
ServerSocket server = new ServerSocket(10001);//端口设为10001

Socket socket;
while((socket = server.accept())!=null)
{
clientList.add(socket);
//clientName = socket.getInetAddress().toString();
//output = new DataOutputStream(socket.getOutputStream());
//input = new DataInputStream(socket.getInputStream());
new readClient(socket).start();
new writeClient(socket).start();
}
}
catch(Exception e)
{System.out.println(e.toString());}
}

public class readClient extends Thread
{
private Socket socket;

public readClient(Socket client)
{socket = client;}

public void run()
{
String msg;
try
{
String clientName = socket.getInetAddress().toString();
DataOutputStream output = new DataOutputStream(socket.getOutputStream());
DataInputStream input = new DataInputStream(socket.getInputStream());
while((msg = input.readUTF())!=null)
{
System.out.println("收到消息：【"+clientName+"】 "+msg);
}
}
catch(Exception e){System.out.println(e.toString());}
}
}

public class writeClient extends Thread
{
private Socket socket;

public writeClient(Socket client)
{socket = client;}

public void run()
{
try{

BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
String userInput;
String clientName = socket.getInetAddress().toString();
DataOutputStream output = new DataOutputStream(socket.getOutputStream());
DataInputStream input = new DataInputStream(socket.getInputStream());
while(true)
{
if(stdIn.ready())
{
userInput = stdIn.readLine();
if(userInput!="exit")
{
output.writeUTF(userInput);
System.out.println("已发送消息给【"+clientName+"】"+userInput);
}
}
}
}
catch(Exception e) {System.out.println(e.toString());}
}
}

}

　　 这个程序建立了一个服务器，它一直监听10001端口，等待用户连接。在建立连接后给客户端返回一段信息，然后结束会话。这个程序一次只能接受一个客户连接。

　　 ｛建立客户端｝

package org.tx;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.BufferedReader;
import java.io.InputStreamReader;

public class socketClient
{
private DataOutputStream output;
private DataInputStream input;
private String clientName;

public static void main(String[] args)
{
//在main函数中，启动服务器的socket
new socketClient().ConnectServer();
}

public void ConnectServer()
{
try
{
Socket socket = new Socket("127.0.0.1",10001);//
clientName = socket.getInetAddress().toString();
input = new DataInputStream(socket.getInputStream());
output = new DataOutputStream(socket.getOutputStream());

new readServer().start();
new writeServer().start();
}
catch(Exception e){System.out.println(e.toString());}
}

public class readServer extends Thread
{
private Socket client;

public void run()
{
String msg;
try
{
while(true)
{
msg = input.readUTF();
if(msg!=null)
System.out.println("收到消息：【"+clientName+"】 "+msg);
}
}
catch(Exception e) {System.out.println(e.toString());}
}
}

public class writeServer extends Thread
{
private Socket client;

public void run()
{
try
{
BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
String userInput;
while(true)
{
if(stdIn.ready())
{
userInput = stdIn.readLine();
if(userInput!="exit")
{
output.writeUTF(userInput);
System.out.println("已发送消息给【"+clientName+"】"+userInput);
}
}
}
}
catch(Exception e) {System.out.println(e.toString());}
}
}

}

　　 多个客户同时连接，主程序监听一端口，等待客户接入；同时构造一个线程类，准备接管会话。当一个Socket会话产生后，将这个会话交给线程处理，然后主程序继续监听。运用Thread类或Runnable接口来实现是不错的办法。这个客户端连接到地址为xxx.xxx.xxx.xxx的服务器，端口为10001，并从键盘输入一行信息，发送到服务器，然后接受服务器的返回信息，最后结束会话。