Socket是指在一個特定編程模型下，進程間通信鏈路的端點。因為這個特定編程模型的流行，Socket這個名字在其他領域得到了復用，包括Java叫技術。
如果要建立連接，一臺機器必須運行一個進程來等待連接，而另一臺機器必須試圖到達第一臺機器。這個電話系統(tǒng)類似：一方必須發(fā)起呼叫，而另一方在此時必須等待電話呼叫。
java網(wǎng)絡模型圖
下面通過一個有“回顯”功能的服務器和客戶端來介紹應用java.net包編寫網(wǎng)絡應用程序。
這個例子主要功能是服務器端的程序等待客戶的輸入，然后將讀取到的信息回顯給客戶端，同時在服務器端的控制臺輸出。而客戶端從控制臺接收信息后，向客戶端發(fā)送輸入，并接收服務器的回顯數(shù)據(jù)，然后顯示在控制臺。
客戶端程序代碼如下：
package com.javapp.ch11;
import java.io.*;
import java.net.*;
/**
* Description: 具有“回顯”功能的服務器端和客戶端程序
*/
public class EchoClientDemo {
// 服務器端的服務端口。
public static final int SERVERPORT = 990;
public static void main(String[] args) {
try {
// 建立連接套接字。
Socket s = new Socket("localhost",SERVERPORT);
System.out.println("socket = " + s);
// 新建網(wǎng)絡連接的輸入流。
BufferedReader in = new BufferedReader(new InputStreamReader(s
.getInputStream()));
// 新建網(wǎng)絡連接的自動刷新的輸出流。
PrintWriter out = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(s.getOutputStream())),true);
// 先使用System.in構造InputStreamReader，再構造BufferedReader。
BufferedReader stdin = new BufferedReader(
new InputStreamReader(System.in));
System.out.println("Enter a string， Enter BYE to exit! ");
while (true) {
// 讀取從控制臺輸入的字符串，并向網(wǎng)絡連接輸出，即向服務器端發(fā)送數(shù)據(jù)。
out.println(stdin.readLine());
// 從網(wǎng)絡連接讀取一行，即接收服務器端的數(shù)據(jù)。
String str = in.readLine();
// 如果接收到的數(shù)據(jù)為空（如果直接按Enter，不是空數(shù)據(jù)），則退出循環(huán)，關閉連接。
if (str == null) {
break;
}
System.out.println(str);
}
s.close();
} catch (IOException e) {
System.err.println("IOException" + e.getMessage());
}
}
}
上面客戶端程序中。首先用java.net包中的Socket類建立一個連接套接字，其后應用的Socket對象的getInputStream方法從服務器接收數(shù)據(jù)，并且應用Socket對象的getOuputStream方法發(fā)送數(shù)據(jù)到服務器。創(chuàng)建完輸入輸出流，就可以像讀寫文件的方式來讀寫數(shù)據(jù)。支持多客戶端的“回顯”服務器端程序代碼如下：
package com.javapp.ch11;
import java.io.*;
import java.net.*;
/**
* Description:支持多客戶端的“回顯”服務器端程序
*/
public class EchoServerThreadDemo {
// 服務器端的服務端口。
public static final int SERVERPORT = 990;
public static void main(String[] args) {
try {
// 已經(jīng)連接上的客戶端的序號。
int number = 1;
// 建立服務器端傾聽套接字。
ServerSocket s = new ServerSocket(SERVERPORT);
System.out.println("Started: " + s);
while (true) {
// 等待并接收請求，建立連接套接字。
Socket incoming = s.accept();
System.out.println("Connection " + number + " accepted: ");
System.out.println(incoming);
// 啟動一個線程來進行服務器端和客戶端的數(shù)據(jù)傳輸。
// 主程序繼續(xù)監(jiān)聽是否有請求到來。
Thread t = new EchoThread(incoming,number);
t.start();
number++;
}
} catch (IOException e) {
System.err.println("IOException");
}
}
}
class EchoThread extends Thread {
private Socket s;
int n;
public EchoThread(Socket incoming,int number) {
s = incoming;
n = number;
}
public void run() {
try {
// 新建網(wǎng)絡連接的輸入流。
BufferedReader in = new BufferedReader(new InputStreamReader(s
.getInputStream()));
// 新建網(wǎng)絡連接的自動刷新的輸出流。
PrintWriter out = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(s.getOutputStream())),true);
System.out.println("Hello! Enter BYE to exit.");
// 回顯客戶端的輸入。
while (true) {
// 從網(wǎng)絡連接讀取一行，即接收客戶端的數(shù)據(jù)。
String line = in.readLine();
// 如果接收到的數(shù)據(jù)為空（如果直接按Enter，不是空數(shù)據(jù)），則退出循環(huán)，關閉連接。
if (line == null) {
break;
} else {
if (line.trim().equals("BYE")) {
System.out.println("The client " + n + " entered BYE!");
System.out.println("Connection " + n + " will be closed!");
break;
}
System.out.println("Echo " + n + ": " + line);
// 向網(wǎng)絡連接輸出一行，即向客戶端發(fā)送數(shù)據(jù)。
out.println("Echo " + n + ": " + line);
}
}
// 關閉套接字。
s.close();
} catch (IOException e) {
System.err.println("IOException");
}
}
}
在服務器端程序中，首先用java.net包中的ServerSocket類創(chuàng)建一個服務器端偵聽套接字。其后應用ServerSocket類的accept方法等待并接收用戶請求。當服務器每接收到一個連接請求后，就啟動一個線程來單獨處理服務器和客戶端的數(shù)據(jù)傳輸。服務器端數(shù)據(jù)的接收和發(fā)送與上面介紹的客戶端數(shù)據(jù)的發(fā)送和介紹相同。
