|
第一步 充分理解Socket
1.什么是socket
所謂socket通常也稱作"套接字"，用于描述IP地址和端口，是一個通信鏈的句柄。應(yīng)用程序通常通過"套接字"向網(wǎng)絡(luò)發(fā)出請求或者應(yīng)答網(wǎng)絡(luò)請求。
以J2SDK-1.3為例，Socket和ServerSocket類庫位于java.net包中。ServerSocket用于服務(wù)器端，Socket是建立網(wǎng)絡(luò)連接時使用的。在連接成功時，應(yīng)用程序兩端都會產(chǎn)生一個Socket實(shí)例，操作這個實(shí)例，完成所需的會話。對于一個網(wǎng)絡(luò)連接來說，套接字是平等的，并沒有差別，不因?yàn)樵诜⻊?wù)器端或在客戶端而產(chǎn)生不同級別。不管是Socket還是ServerSocket它們的工作都是通過SocketImpl類及其子類完成的。
重要的Socket API：
java.net.Socket繼承于java.lang.Object，有八個構(gòu)造器，其方法并不多，下面介紹使用最頻繁的三個方法，其它方法大家可以見JDK-1.3文檔。
. Accept方法用于產(chǎn)生"阻塞"，直到接受到一個連接，并且返回一個客戶端的Socket對象實(shí)例。"阻塞"是一個術(shù)語，它使程序運(yùn)行暫時"停留"在這個地方，直到一個會話產(chǎn)生，然后程序繼續(xù)；通常"阻塞"是由循環(huán)產(chǎn)生的。
. getInputStream方法獲得網(wǎng)絡(luò)連接輸入，同時返回一個IutputStream對象實(shí)例，。
. getOutputStream方法連接的另一端將得到輸入，同時返回一個OutputStream對象實(shí)例。
注意：其中g(shù)etInputStream和getOutputStream方法均會產(chǎn)生一個IOException，它必須被捕獲，因?yàn)樗鼈兎祷氐牧鲗ο螅ǔ６紩涣硪粋�流對象使用。
2.如何開發(fā)一個Server-Client模型的程序
開發(fā)原理：
服務(wù)器，使用ServerSocket監(jiān)聽指定的端口，端口可以隨意指定（由于1024以下的端口通常屬于保留端口，在一些操作系統(tǒng)中不可以隨意使用，所以建議使用大于1024的端口），等待客戶連接請求，客戶連接后，會話產(chǎn)生；在完成會話后，關(guān)閉連接。
客戶端，使用Socket對網(wǎng)絡(luò)上某一個服務(wù)器的某一個端口發(fā)出連接請求，一旦連接成功，打開會話；會話完成后，關(guān)閉Socket。客戶端不需要指定打開的端口，通常臨時的、動態(tài)的分配一個1024以上的端口。
｛建立服務(wù)器｝
import java.net.*;
import java.io.*;
public class Server
{
private ServerSocket ss;
private Socket socket;
private BufferedReader in;
private PrintWriter out;
public Server()
{
try
{
ss = new ServerSocket(10000);
while (true)
{
socket = ss.accept();
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(),true);
String line = in.readLine();
out.println("you input is :" + line);
out.close();
in.close();
socket.close();
}
ss.close();
}
catch (IOException e)
{}
}
public static void main(String[] args)
{
new Server();
}
}
這個程序建立了一個服務(wù)器，它一直監(jiān)聽10000端口，等待用戶連接。在建立連接后給客戶端返回一段信息，然后結(jié)束會話。這個程序一次只能接受一個客戶連接。
｛建立客戶端｝
import java.io.*;
import java.net.*;
public class Client
{
Socket socket;
BufferedReader in;
PrintWriter out;
public Client()
{
try
{
socket = new Socket("xxx.xxx.xxx.xxx", 10000);
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(),true);
BufferedReader line = new BufferedReader(new InputStreamReader(System.in));
out.println(line.readLine());
line.close();
out.close();
in.close();
socket.close();
}
catch (IOException e)
{}
}
public static void main(String[] args)
{
new Client();
}
}
這個客戶端連接到地址為xxx.xxx.xxx.xxx的服務(wù)器，端口為10000，并從鍵盤輸入一行信息，發(fā)送到服務(wù)器，然后接受服務(wù)器的返回信息，最后結(jié)束會話。
|
