java的網路程式設計(概括比較全面)
對java網路程式設計Socket(套接字)介面的使用做詳細的介紹和使用。
一.網路程式設計中兩個主要的問題
一個是如何準確的定位網路上一臺或多臺主機,另一個就是找到主機後如何可靠高效的進行資料傳輸。
在TCP/IP協議中IP層主要負責網路主機的定位,資料傳輸的路由,由IP地址可以唯一地確定Internet上的一臺主機。
而TCP層則提供面向應用的可靠(tcp)的或非可靠(UDP)的資料傳輸機制,
這是網路程式設計的主要物件,一般不需要關心IP層是如何處理資料的。
目前較為流行的網路程式設計模型是客戶機/伺服器(C/S)結構。
即通訊雙方一方作為伺服器等待客戶提出請求並予以響應。
客戶則在需要服務時向伺服器提 出申請。
伺服器一般作為守護程序始終執行,監聽網路埠,一旦有客戶請求,
就會啟動一個服務程序來響應該客戶,同時自己繼續監聽服務埠,使後來的客戶也 能及時得到服務。
二.兩類傳輸協議:TCP;UDP
TCP是Tranfer Control Protocol的 簡稱,是一種面向連線的保證可靠傳輸的協議。
通過TCP協議傳輸,得到的是一個順序的無差錯的資料流。
傳送方和接收方的成對的兩個socket之間必須建 立連線,
以便在TCP協議的基礎上進行通訊,當一個socket(通常都是server socket)等待建立連線時,
另一個socket可以要求進行連線,一旦這兩個socket連線起來,
它們就可以進行雙向資料傳輸,雙方都可以進行傳送 或接收操作。
UDP是User Datagram Protocol的簡稱,是一種無連線的協議,
每個資料報都是一個獨立的資訊,包括完整的源地址或目的地址,它在網路上以任何可能的路徑傳往目的地,
因此能否到達目的地,到達目的地的時間以及內容的正確性都是不能被保證的。
(一)比較:UDP和TCP
UDP:
1.每個資料報中都給出了完整的地址資訊,因此無需要建立傳送方和接收方的連線。
2.UDP傳輸資料時是有大小限制的,每個被傳輸的資料報必須限定在64KB之內。
3.UDP是一個不可靠的協議,傳送方所傳送的資料報並不一定以相同的次序到達接收方
TCP:
1.面向連線的協議,在socket之間進行資料傳輸之前必然要建立連線,所以在TCP中需要連線時間。
2.TCP傳輸資料大小限制,一旦連線建立起來,雙方的socket就可以按統一的格式傳輸大的資料。
3.TCP是一個可靠的協議,它確保接收方完全正確地獲取傳送方所傳送的全部資料。
(二)應用:
1.TCP在網路通訊上有極強的生命力,
例如遠端連線(Telnet)和檔案傳輸(FTP)都需要不定長度的資料被可靠地傳輸。
但是可靠的傳輸是要付出代價的,對資料內容正確性的檢驗必然佔用計算機的處理時間和網路的頻寬,
因此TCP傳輸的效率不如UDP高。
2.UDP操作簡單,而且僅需要較少的監護,
因此通常用於區域網高可靠性的分散系統中client/server應用程式。
例如視訊會議系統,並不要求音訊視訊資料絕對的正確,只要保證連貫性就可以了,
這種情況下顯然使用UDP會更合理一些。
三.基於Socket的java網路程式設計
(一)Socket的定義
網路上的兩個程式通過一個雙向的通訊連線實現資料的交換,這個雙向鏈路的一端稱為一個Socket。
Socket通常用來實現客戶方和服務方的連線。Socket是TCP/IP協議的一個十分流行的程式設計介面,
一個Socket由一個IP地址和一個埠號唯一確定。
但是,Socket所支援的協議種類也不光TCP/IP一種,因此兩者之間是沒有必然聯絡的。
在Java環境下,Socket程式設計主要是指基於TCP/IP協議的網路程式設計。
(二)Socket通訊的過程
Server端Listen(監聽)某個埠是否有連線請求,Client端向Server 端發出Connect(連線)請求,
Server端向Client端發回Accept(接受)訊息。一個連線就建立起來了。
Server端和Client 端都可以通過Send,Write(socket.getOutputStream/socket.getInputStream)等方法與對方通訊。
對於一個功能齊全的Socket,都要包含以下基本結構,其工作過程包含以下四個基本的步驟:
1. 建立Socket;
2. 開啟連線到Socket的輸入/出流;
3. 按照一定的協議對Socket進行讀/寫操作;
4.關閉Socket.(在實際應用中,並未使用到顯示的close,雖然很多文章都推薦如此,不過在我的程式中,可能因為程式本身比較簡單,要求不高,所以並未造成什麼影響。)
(三)建立Socket
建立Socket在java包java.net中提供了兩個類Socket和ServerSocket,
分別用來表示雙向連線的客戶端和服務端。這是兩個封裝得非常好的類,使用很方便。其構造方法如下:
客戶端類的構造器:
Socket(InetAddress address, int port);
Socket(InetAddress address, int port, boolean stream);
Socket(String host, int prot); //主要使用
Socket(String host, int prot, boolean stream);
Socket(SocketImpl impl)
Socket(String host, int port, InetAddress localAddr, int localPort)
Socket(InetAddress address, int port, InetAddress localAddr, int localPort)
服務端類的構造器:
ServerSocket(int port); //主要使用
ServerSocket(int port, int backlog);
ServerSocket(int port, int backlog, InetAddress bindAddr)
其中address、host和port分別是雙向連線中另一方的IP地址、主機名和端 口號,stream指明socket是流socket還是資料報socket,localPort表示本地主機的埠號,localAddr和 bindAddr是本地機器的地址(ServerSocket的主機地址),impl是socket的父類,既可以用來建立serverSocket又可 以用來建立Socket。count則表示服務端所能支援的最大連線數。例如:
Socket client = new Socket("127.0.01", 5555); //127.0.01任何時候都代表本機IP地址,5555是自定義的埠號
ServerSocket server = new ServerSocket(5555);
注意,在選擇埠時,必須小心。每一個埠提供一種特定的服務,
只有給出正確的埠,才 能獲得相應的服務。
0~1023的埠號為系統所保留,例如http服務的埠號為80,telnet服務的埠號為21,ftp服務的埠號為23,
所以我們在選擇埠號時,最好選擇一個大於1023的數以防止發生衝突。
在建立socket時如果發生錯誤,將產生IOException,在程式中必須對之作出處理。所以在建立Socket或ServerSocket是必須捕獲或丟擲例外。
(四)簡單的Client/Server程式
程式實現的功能:
(1)伺服器在每一臺客戶端登陸的時候:傳送一條簡訊給客戶端“伺服器正在向你傳送訊息!”,然後在伺服器端顯示連線上的客戶端主機地址。
(2)客戶端連線上了,會接收到一條簡訊,並且可以對伺服器一直進行傳送簡訊。
(3)伺服器可以一直接收客戶端的簡訊。
(4)這裡伺服器只寫一句話,但是想要像客戶端那樣一直寫也是可以的,改一下就可以了。
1. 伺服器端程式的編寫
package com.xykj.server;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
伺服器端繼承Thread
* 可以實現簡單的互動
* */
public class Server extends Thread {
// 定義伺服器介面ServerSocket
ServerSocket server = null;
// 定義一個伺服器,定義埠
public Server(int port) {
try {
server = new ServerSocket(port);
} catch (IOException e) {
e.printStackTrace();
}
}
// 傳送訊息的執行緒
@Override
public void run() {
super.run();
try {
System.out.println("伺服器在啟動中...等待使用者的連線");
//一直接收使用者的連線,連線之後傳送一條簡訊給使用者
while(true){
// 建立socket介面,accept方法是一個阻塞程序,等到有使用者連線才往下走
// 定義Socket類
Socket socket = server.accept();
//通過socket物件可以獲得輸出流,用來寫資料
OutputStream os = socket.getOutputStream();
// 向客戶端傳送訊息
os.write("伺服器正在向你傳送訊息!".getBytes());
//在伺服器上顯示連線的上的電腦、
System.out.println(socket.getInetAddress().getHostAddress()+"連線上了!");
//通過socket物件可以獲得輸入流,用來讀取使用者資料
InputStream is=socket.getInputStream();
//讀取資料
int len=0;
byte[] buf=new byte[1024];
while ((len=is.read(buf))!=-1) {
//直接把獲得的資料打印出來
System.out.println("伺服器接收到客戶端的資料:"+new String(buf,0,len));
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
伺服器的啟動:
package com.xykj.server;
public class ServerTest {
public static void main(String[] args) {
//這裡伺服器只需要定義一個埠號就可以了,程式會自動獲取IP地址
//但是客戶端需要連線這個伺服器時,需要知道它的IP地址還有埠號
//ip地址的檢視方法:進入cmd視窗,輸入ipconfig/all可以看到
Server server=new Server(6768);
server.start();
}
}
2. 客戶端程式的編寫
package com.xykj.client;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class Client extends Thread {
//定義一個Socket物件
Socket socket = null;
public Client(String host, int port) {
try {
//需要伺服器的IP地址和埠號,才能獲得正確的Socket物件
socket = new Socket(host, port);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void run() {
//客戶端一連線就可以寫資料個伺服器了
new sendMessThread().start();
super.run();
try {
// 讀Sock裡面的資料
InputStream s = socket.getInputStream();
byte[] buf = new byte[1024];
int len = 0;
while ((len = s.read(buf)) != -1) {
System.out.println(new String(buf, 0, len));
}
} catch (IOException e) {
e.printStackTrace();
}
}
//往Socket裡面寫資料,需要新開一個執行緒
class sendMessThread extends Thread{
@Override
public void run() {
super.run();
//寫操作
Scanner scanner=null;
OutputStream os= null;
try {
scanner=new Scanner(System.in);
os= socket.getOutputStream();
String in="";
do {
in=scanner.next();
os.write(("客戶端:"+in).getBytes());
os.flush();
} while (!in.equals("bye"));
} catch (IOException e) {
e.printStackTrace();
}
scanner.close();
try {
os.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
啟動客戶端:
package com.xykj.client2;
public class ClientTest2 {
public static void main(String[] args) {
//需要伺服器的正確的IP地址和埠號
Client2 client2=new Client2("192.168.18.128", 6768);
client2.start();
}
}
程式中要先開啟服務端,在開啟客戶端,否則會報錯!
還有就是一般的電腦是動態的IP地址,每天都在變化。要注意修改!
(五)支援多客戶的client/server程式
在實際應用 中,往往是在伺服器上執行一個永久的程式,它可以接收來自其他多個客戶端的請求,
提供相應的服務。伺服器總是在指定的埠上監聽是否有客戶請求,一旦監聽到客戶請求,
伺服器就會啟動一個專門的服務執行緒來響 應該客戶的請求,
而伺服器本身在啟動完執行緒之後馬上又進入監聽狀態,等待下一個客戶的到來。
並且每一個使用者對應一個固定的執行緒來接收資訊。
伺服器還會把接收到的資訊傳送給所有連線上的客戶端。
示例:多人聊天室的實現:
1.伺服器端的設計
package com.xykj.server2;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
/**
* 可以實現和客戶端的相互發送訊息的互動 可以是多臺電腦
* */
public class Server2 extends Thread {
// 用來存放連線上的使用者的socket物件的值
List list = new ArrayList<>();
// 定義伺服器介面ServerSocket
ServerSocket server = null;
// 定義一個伺服器,定義埠
public Server2(int port) {
try {
server = new ServerSocket(port);
} catch (IOException e) {
e.printStackTrace();
}
}
// 傳送訊息的執行緒
@Override
public void run() {
super.run();
try {
while (true) {
// 建立socket介面,accept方法是一個阻塞程序,等到有使用者連線才往下走
// 定義Socket類
Socket socket = server.accept();
// 在伺服器顯示連線的上的電腦、
String message = socket.getInetAddress().getHostAddress().toString();
System.out.println(message+"連線上了");
// 向用戶傳送訊息
SendMessageToAllUser(message);
// 把連線上的使用者新增到集合;裡面去
list.add(socket);
//開始新連線使用者的執行緒,用於該可以一直讀取資料
new readerThread(socket).start();;
}
} catch (IOException e) {
e.printStackTrace();
}
}
// 把訊息傳送給每一個使用者,涉及到寫的操作OutStream
private void SendMessageToAllUser(String message) {
// 拿到每一個使用者的socket物件,對其進行寫入資料
for (Socket socket : list) {
// 判讀之前儲存的連線是否還在
if (socket != null && socket.isConnected()) {
try {
OutputStream os = socket.getOutputStream();
os.write(message.getBytes());
os.flush();// 重新整理一下寫入的資料,很有必要
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
// 讀取客戶端的資訊
class readerThread extends Thread {
InputStream is = null;
// 這裡傳入一個socket物件,因為每一個使用者都要用一個不同的執行緒存放的socket物件來進行一直讀取資料
public readerThread(Socket socket) {
try {
// 獲取輸入流
is = socket.getInputStream();
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void run() {
super.run();
try {
int len = 0;
byte[] buf = new byte[1024];
while ((len = is.read(buf)) != -1) {
// 把讀取到的資料傳送給其他使用者
SendMessageToAllUser(new String(buf, 0, len));
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
啟動服務端:
package com.xykj.server;
public class ServerTest {
public static void main(String[] args) {
//這裡伺服器只需要定義一個埠號就可以了,IP地址程式會自動獲取
//但是客戶端需要連線這個伺服器時,需要知道它的IP地址還有埠號
//ip地址的檢視方法:進入cmd視窗,輸入ipconfig/all可以看到
Server2 server=new Server2(6768);
server.start();
}
}
2.客戶端的設計
這個和上個例子的客戶端的設計基本一樣,就不再重複貼上了。
總結:上面主要是對java網路程式設計Socket介面類的使用,
還有TCP協議的應用(Socket的主要應用),
當然TCP還有一個比較主要的應用就是檔案傳輸,
其中涉及到比較複雜的字串處理(接收前和接收後都要),
有興趣的可以自己設計一下。