數據庫中java的DatagramPacket

數據庫中java的DatagramPacket

自尋址套接字（Datagram Sockets）

　　，因為使用流套接字的每個連接均要花費一定的時間，要減少這種開銷，網絡API提供了第二種套接字：自尋址套接字 （datagram socket），自尋址使用UDP發送尋址信息（從客戶程序到服務程序或從服務程序到客戶程序），不同的是可以通過自尋址套接字發送 多IP信息包，自尋址信息包含在自尋址包中，此外自尋址包又包含在IP包內，這就將尋址信息長度限制在60000字節內。圖2顯示了位于IP包內的自尋址 包的自尋址信息。

　　與TCP保證信息到達信息目的地的方式不同，UDP提供了另外一種方法，如果自尋址信息包沒有到達目的地，，那么UDP也不會請求發送者重新發 送自尋址包，這是因為UDP在每一個自尋址包中包含了錯誤檢測信息，在每個自尋址包到達目的地之后UDP只進行簡單的錯誤檢查，如果檢測失敗，UDP將拋 棄這個自尋址包，也不會從發送者那里重新請求替代者，這與通過郵局發送信件相似，發信人在發信之前不需要與收信人建立連接，同樣也不能保證信件能到達收信 人那里

　　自尋址套接字工作包括下面三個類：DatagramPacket, DatagramSocket,和 MulticastSocket。 DatagramPacket對象描繪了自尋址包的地址信息，DatagramSocket表示客戶程序和服務程序自尋址套接 字，MulticastSocket描繪了能進行多點傳送的自尋址套接字，這三個類均位于java.net包內。

　　DatagramPacket類

　　在使用自尋址包之前，你需要首先熟悉DatagramPacket類，地址信息和自尋址包以字節數組的方式同時壓縮入這個類創建的對象中

　　DatagramPacket有數個構造函數，即使這些構造函數的形式不同，但通常情況下他們都有兩個共同的參 數：byte [] buffer 和 int length，buffer參數包含了一個對保存自尋址數據包信息的字節數組的引用，length表示字 節數組的長度。

　　最簡單的構造函數是DatagramPacket(byte [] buffer, int length)，這個構造函數確定了自尋址數據包 數組和數組的長度，但沒有任何自尋址數據包的地址和端口信息，這些信息可以后面通過調用方法setAddress(InetAddress addr)和 setPort(int port)添加上，下面的代碼示范了這些函數和方法。

byte [] buffer = new byte [100];
DatagramPacket dgp = new DatagramPacket (buffer, buffer.length);
InetAddress ia = InetAddress.getByName ("dgp.setAddress (ia);
dgp.setPort (6000); // Send datagram packet to port 6000.

byte [] buffer = new byte [100];
InetAddress ia = InetAddress.getByName ("DatagramPacket dgp = new DatagramPacket (buffer, buffer.length, ia,
6000);

　　DatagramSocket類在客戶端創建自尋址套接字與服務器端進行通信連接，并發送和接受自尋址套接字。雖然有多個構造函數可供選擇，但 我發現創建客戶端自尋址套接字最便利的選擇是DatagramSocket()函數，而服務器端則是DatagramSocket(int port)函 數，如果未能創建自尋址套接字或綁定自尋址套接字到本地端口，那么這兩個函數都將拋出一個SocketException對象，一旦程序創建了 DatagramSocket對象，那么程序分別調用send(DatagramPacket dgp) 和 receive(DatagramPacket dgp)來發送和接收自尋址數據包，

　　List4顯示的DGSClient源代碼示范了如何創建自尋址套接字以及如何通過套接字處理發送和接收信息

Listing 4: DGSClient.java
// DGSClient.java

import java.io.*;
import java.net.*;

class DGSClient
{
public static void main (String [] args)
{
String host = "localhost";

　　// If user specifies a command-line argument, that argument
// represents the host name.

if (args.length == 1)
host = args [0];

　　DatagramSocket s = null;

　　try
{
// Create a datagram socket bound to an arbitrary port.

　　　s = new DatagramSocket ();

　　　// Create a byte array that will hold the data portion of a
// datagram packet's message. That message originates as a
// String object, which gets converted to a sequence of
// bytes when String's getBytes() method is called. The
// conversion uses the platform's default character set.

　　　byte [] buffer;
buffer = new String ("Send me a datagram").getBytes ();

　　　// Convert the name of the host to an InetAddress object.
// That object contains the IP address of the host and is
// used by DatagramPacket.

　　　InetAddress ia = InetAddress.getByName (host);

　　　// Create a DatagramPacket object that encapsulates a
// reference to the byte array and destination address
// information. The destination address consists of the
// host's IP address (as stored in the InetAddress object)
// and port number 10000 -- the port on which the server
// program listens.

　　　DatagramPacket dgp = new DatagramPacket (buffer,
buffer.length,
ia,
10000);

　　　// Send the datagram packet over the socket.

　　　s.send (dgp);

　　　// Create a byte array to hold the response from the server.
// program.

　　　byte [] buffer2 = new byte [100];

　　　// Create a DatagramPacket object that specifies a buffer
// to hold the server program's response, the IP address of
// the server program's computer, and port number 10000.

　　　dgp = new DatagramPacket (buffer2,
buffer.length,
ia,
10000);

　　　// Receive a datagram packet over the socket.

　　　s.receive (dgp);

　　　// Print the data returned from the server program and stored
// in the datagram packet.

　　　System.out.println (new String (dgp.getData ()));

　　}
catch (IOException e)
{
System.out.println (e.toString ());
}
finally
{
if (s != null)
s.close ();　
}
}
}

DGSClient由創建一個綁定任意本地（客戶端）端口好的DatagramSocket對象開始，然后裝入帶有文本信息的數組buffer和描述 服務器主機IP地址的InetAddress子類對象的引用，接下來，DGSClient創建了一個DatagramPacket對象，該對象加入了帶文 本信息的緩沖器的引用，InetAddress子類對象的引用，以及服務端口號10000, DatagramPacket的自尋址數據包通過方法 sent()發送給服務器程序，于是一個包含服務程序響應的新的DatagramPacket對象被創建，receive()得到響應的自尋址數據包，然 后自尋址數據包的getData()方法返回該自尋址數據包的一個引用，最后關閉DatagramSocket。

　　DGSServer服務程序補充了DGSClient的不足，List5是DGSServer的源代碼：

Listing 5: DGSServer.java
// DGSServer.java

import java.io.*;
import java.net.*;

class DGSServer
{
public static void main (String [] args) throws IOException
{
System.out.println ("Server starting ...\n");

　　// Create a datagram socket bound to port 10000. Datagram
// packets sent from client programs arrive at this port.

　　DatagramSocket s = new DatagramSocket (10000);

　　// Create a byte array to hold data contents of datagram
// packet.

　　byte [] data = new byte [100];

　　// Create a DatagramPacket object that encapsulates a reference
// to the byte array and destination address information. The
// DatagramPacket object is not initialized to an address
// because it obtains that address from the client program.

　　DatagramPacket dgp = new DatagramPacket (data, data.length);

　　// Enter an infinite loop. Press Ctrl+C to terminate program.

　　while (true)
{
// Receive a datagram packet from the client program.

　　　s.receive (dgp);

　　　// Display contents of datagram packet.

　　　System.out.println (new String (data));

　　　// Echo datagram packet back to client program.

　　s.send (dgp);
}
}
}

 
多點傳送和MulticastSocket類

　　前面的例子顯示了服務器程序線程發送單一的消息（通過流套接字或自尋址套接字）給唯一的客戶端程序，這種行為被稱為單點傳送 （unicasting），多數情況都不適合于單點傳送，比如，搖滾歌手舉辦一場音樂會將通過互聯網進行播放，畫面和聲音的質量依賴于傳輸速度，服務器程 序要傳送大約10億字節的數據給客戶端程序，使用單點傳送，那么每個客戶程序都要要復制一份數據，如果，互聯網上有10000個客戶端要收看這個音樂會， 那么服務器程序通過Internet要傳送10000G的數據，這必然導致網絡阻塞，降低網絡的傳輸速度。

　　如果服務器程序要將同一信息發送給多個客戶端，那么服務器程序和客戶程序可以利用多點傳送（multicasting）方式進行通信。多點傳送 就是服務程序對專用的多點傳送組的IP地址和端口發送一系列自尋址數據包，通過加入操作IP地址被多點傳送Socket注冊，通過這個點客戶程序可以接收 發送給組的自尋址包（同樣客戶程序也可以給這個組發送自尋址包），一旦客戶程序讀完所有要讀的自尋址數據包，那么可以通過離開組操作離開多點傳送組。

原文轉自：http://www.anti-gravitydesign.com