重復(fù)和并發(fā)服務(wù)器
這個(gè)應(yīng)用程序被當(dāng)作一個(gè)重復(fù)的服務(wù)器.因?yàn)樗挥性谔幚硗暌粋€(gè)進(jìn)程以后才會(huì)接受另一 個(gè)連接.更多的復(fù)雜服務(wù)器是并發(fā)的.它為每一個(gè)請(qǐng)求分配一個(gè)線程,而不是來(lái)一個(gè)處理一 個(gè).所以看起來(lái)它在同時(shí)處理多人請(qǐng)求.所有的商業(yè)的服務(wù)器都是并發(fā)的服務(wù)器. Java數(shù)據(jù)報(bào)類
不像面向連接的類,數(shù)據(jù)報(bào)的客戶端和服務(wù)器端的類在表面上是一樣的.下面的程序建立 了一個(gè)客戶和服務(wù)器商的數(shù)據(jù)報(bào)sockets:
DatagramSocket serverSocket = new DatagramSocket( 4545 );
DatagramSocket clientSocket = new DatagramSocket();
服務(wù)器用參數(shù)4545來(lái)指定端口號(hào),由于客戶端將要呼叫服務(wù)器,客戶端可以利用可利用的 端口.如果省略第二個(gè)參數(shù),程序會(huì)讓操作系統(tǒng)分配一個(gè)可用的端口.客戶端可以請(qǐng)求一個(gè) 指定的端口,但是如果其它的應(yīng)用程序已經(jīng)綁定到這個(gè)端口之上,請(qǐng)求將會(huì)失敗.如果你的 意圖不是作為一個(gè)服務(wù)器,不要指定端口. 由于流不能由交談得到,那么我么如何與一個(gè)數(shù)據(jù)報(bào)Socket進(jìn)行對(duì)話.答案在于數(shù)據(jù)報(bào)類.
接收數(shù)據(jù)報(bào)
DatagramPacket類是用來(lái)通過(guò)DatagramSocket類接收和發(fā)送數(shù)據(jù)的類.packet類包括了連 接信息和數(shù)據(jù).就如前面所說(shuō)的一樣,數(shù)據(jù)報(bào)是自身獨(dú)立的傳輸單元.DatagramPacket類壓
縮了這些單元.下面的程序表示了用一個(gè)數(shù)據(jù)報(bào)socket來(lái)接收數(shù)據(jù):
DatagramPacket packet = new DatagramPacket(new byte[512], 512); clientSocket
.receive(packet);
clientSocket.receive(packet);
packet的構(gòu)建器需要知道將得到的數(shù)據(jù)放在哪兒.一個(gè)512字節(jié)的緩存被建立并且作為構(gòu)建器的第二個(gè)參數(shù).每二個(gè)構(gòu)建器參數(shù)是緩存的大小.就像ServerSocket類的accept()方 法一樣,receive()方法在數(shù)據(jù)可用之前將會(huì)阻塞.
發(fā)送數(shù)據(jù)報(bào)
發(fā)送數(shù)據(jù)報(bào)是非常地簡(jiǎn)單地,所有需要的只是一個(gè)地址.地址是由InetAddress類來(lái)建立的.這個(gè)類沒(méi)有公共的構(gòu)建器,但是它有幾個(gè)static的方法,可以用來(lái)建立這個(gè)類的實(shí)例.下面的列表列出了建立InetAddress類的實(shí)例的方法:
Public InetAddress Creation Methods
InetAddress getByName(String host);
InetAddress[] getAllByName(String host);
InetAddress getLocalHost();
得到本地主機(jī)的地址是非常地有用的,只有前面兩個(gè)方法是用來(lái)發(fā)送數(shù)據(jù)包的.getByName()和getAllByName()需要目的主機(jī)的地址.第一個(gè)方法僅僅只是返回第一個(gè)符合條件的東西.第二個(gè)方法是必須的,因?yàn)橐慌_(tái)計(jì)算機(jī)可能有多個(gè)地址.在這種情況下,這臺(tái)計(jì)算機(jī)被稱為multi-homed.
所有的建立的方法都被標(biāo)記為static.它們必須像下面這樣得到調(diào)用:
InetAddress addr1 = InetAddress.getByName(\"merlin\");
InetAddress addr2[] = InetAddress.getAllByName(\"merlin\");
InetAddress addr3 = InetAddress.getLocalHost();
重復(fù)和并發(fā)服務(wù)器
所有的這些調(diào)用都可以擲出一個(gè)UnknownHostException違例.如果一臺(tái)計(jì)算機(jī)沒(méi)有連接上 DNS服務(wù)器,或者主機(jī)的確沒(méi)有找到,這個(gè)違例就會(huì)被擲出.如果一臺(tái)計(jì)算機(jī)沒(méi)有一個(gè)激活
的TCP/IP配置,getLocalHost()也為失敗并擲出一個(gè)違例. 一旦一個(gè)地址被確定了,數(shù)據(jù)報(bào)就可以被送出了.下面的程序傳輸了一個(gè)字符串給目的socket:
String toSend = \"This is the data to send!\");
byte[] sendbuf = new byte[ toSend.length() ];
toSend.getBytes( 0, toSend.length(), sendbuf, 0 );
DatagramPacket sendPacket = new DatagramPacket( sendbuf, sendbuf.length,
addr, port);
clientSocket.send( sendPacket );
首先,字符串必須被轉(zhuǎn)換成一個(gè)字節(jié)數(shù)組.然后,一個(gè)新的DatagramPacket實(shí)例必須被建立.注意構(gòu)建器的最后兩個(gè)參數(shù).因?yàn)橐l(fā)送一個(gè)包,所以地址和端口必須被給定.一個(gè)applet可能可以知道它的服務(wù)器的地址,但是服務(wù)器如何知道它的客戶機(jī)的地址呢.當(dāng)任何一個(gè)包被收到后,返回的地址和端口會(huì)被解壓出來(lái),并通過(guò)getAddress()和getPort()方法得到.這就是一個(gè)服務(wù)器如何回應(yīng)一個(gè)客戶端的包:
DatagramPacket sendPacket = new DatagramPacket( sendbuf, sendbuf.length,
recvPacket.getAddress(), recvPacket.getPort() );
serverSocket.send( sendPacket );
不像面向連接的操作,數(shù)據(jù)報(bào)服務(wù)器服務(wù)器其實(shí)比數(shù)據(jù)報(bào)客戶端更簡(jiǎn)單:
數(shù)據(jù)報(bào)服務(wù)器
一個(gè)數(shù)據(jù)報(bào)服務(wù)器的基本步驟:
1.在一個(gè)指定的端口上建立一個(gè)數(shù)據(jù)報(bào)socket.
2.用receive方法等待進(jìn)來(lái)的包.
3.用特定的協(xié)議來(lái)回應(yīng)收到的包.
4.回到第二步或繼續(xù)第二步.
5.關(guān)閉數(shù)據(jù)報(bào)socket.
列表9.3演示了一人簡(jiǎn)單的數(shù)據(jù)報(bào)回應(yīng)服務(wù)器.它將回應(yīng)它收到的包.
列表9.3.一個(gè)簡(jiǎn)單的數(shù)據(jù)報(bào)回應(yīng)服務(wù)器
import java.io.*;
這個(gè)應(yīng)用程序被當(dāng)作一個(gè)重復(fù)的服務(wù)器.因?yàn)樗挥性谔幚硗暌粋€(gè)進(jìn)程以后才會(huì)接受另一 個(gè)連接.更多的復(fù)雜服務(wù)器是并發(fā)的.它為每一個(gè)請(qǐng)求分配一個(gè)線程,而不是來(lái)一個(gè)處理一 個(gè).所以看起來(lái)它在同時(shí)處理多人請(qǐng)求.所有的商業(yè)的服務(wù)器都是并發(fā)的服務(wù)器. Java數(shù)據(jù)報(bào)類
不像面向連接的類,數(shù)據(jù)報(bào)的客戶端和服務(wù)器端的類在表面上是一樣的.下面的程序建立 了一個(gè)客戶和服務(wù)器商的數(shù)據(jù)報(bào)sockets:
DatagramSocket serverSocket = new DatagramSocket( 4545 );
DatagramSocket clientSocket = new DatagramSocket();
服務(wù)器用參數(shù)4545來(lái)指定端口號(hào),由于客戶端將要呼叫服務(wù)器,客戶端可以利用可利用的 端口.如果省略第二個(gè)參數(shù),程序會(huì)讓操作系統(tǒng)分配一個(gè)可用的端口.客戶端可以請(qǐng)求一個(gè) 指定的端口,但是如果其它的應(yīng)用程序已經(jīng)綁定到這個(gè)端口之上,請(qǐng)求將會(huì)失敗.如果你的 意圖不是作為一個(gè)服務(wù)器,不要指定端口. 由于流不能由交談得到,那么我么如何與一個(gè)數(shù)據(jù)報(bào)Socket進(jìn)行對(duì)話.答案在于數(shù)據(jù)報(bào)類.
接收數(shù)據(jù)報(bào)
DatagramPacket類是用來(lái)通過(guò)DatagramSocket類接收和發(fā)送數(shù)據(jù)的類.packet類包括了連 接信息和數(shù)據(jù).就如前面所說(shuō)的一樣,數(shù)據(jù)報(bào)是自身獨(dú)立的傳輸單元.DatagramPacket類壓
縮了這些單元.下面的程序表示了用一個(gè)數(shù)據(jù)報(bào)socket來(lái)接收數(shù)據(jù):
DatagramPacket packet = new DatagramPacket(new byte[512], 512); clientSocket
.receive(packet);
clientSocket.receive(packet);
packet的構(gòu)建器需要知道將得到的數(shù)據(jù)放在哪兒.一個(gè)512字節(jié)的緩存被建立并且作為構(gòu)建器的第二個(gè)參數(shù).每二個(gè)構(gòu)建器參數(shù)是緩存的大小.就像ServerSocket類的accept()方 法一樣,receive()方法在數(shù)據(jù)可用之前將會(huì)阻塞.
發(fā)送數(shù)據(jù)報(bào)
發(fā)送數(shù)據(jù)報(bào)是非常地簡(jiǎn)單地,所有需要的只是一個(gè)地址.地址是由InetAddress類來(lái)建立的.這個(gè)類沒(méi)有公共的構(gòu)建器,但是它有幾個(gè)static的方法,可以用來(lái)建立這個(gè)類的實(shí)例.下面的列表列出了建立InetAddress類的實(shí)例的方法:
Public InetAddress Creation Methods
InetAddress getByName(String host);
InetAddress[] getAllByName(String host);
InetAddress getLocalHost();
得到本地主機(jī)的地址是非常地有用的,只有前面兩個(gè)方法是用來(lái)發(fā)送數(shù)據(jù)包的.getByName()和getAllByName()需要目的主機(jī)的地址.第一個(gè)方法僅僅只是返回第一個(gè)符合條件的東西.第二個(gè)方法是必須的,因?yàn)橐慌_(tái)計(jì)算機(jī)可能有多個(gè)地址.在這種情況下,這臺(tái)計(jì)算機(jī)被稱為multi-homed.
所有的建立的方法都被標(biāo)記為static.它們必須像下面這樣得到調(diào)用:
InetAddress addr1 = InetAddress.getByName(\"merlin\");
InetAddress addr2[] = InetAddress.getAllByName(\"merlin\");
InetAddress addr3 = InetAddress.getLocalHost();
重復(fù)和并發(fā)服務(wù)器
所有的這些調(diào)用都可以擲出一個(gè)UnknownHostException違例.如果一臺(tái)計(jì)算機(jī)沒(méi)有連接上 DNS服務(wù)器,或者主機(jī)的確沒(méi)有找到,這個(gè)違例就會(huì)被擲出.如果一臺(tái)計(jì)算機(jī)沒(méi)有一個(gè)激活
的TCP/IP配置,getLocalHost()也為失敗并擲出一個(gè)違例. 一旦一個(gè)地址被確定了,數(shù)據(jù)報(bào)就可以被送出了.下面的程序傳輸了一個(gè)字符串給目的socket:
String toSend = \"This is the data to send!\");
byte[] sendbuf = new byte[ toSend.length() ];
toSend.getBytes( 0, toSend.length(), sendbuf, 0 );
DatagramPacket sendPacket = new DatagramPacket( sendbuf, sendbuf.length,
addr, port);
clientSocket.send( sendPacket );
首先,字符串必須被轉(zhuǎn)換成一個(gè)字節(jié)數(shù)組.然后,一個(gè)新的DatagramPacket實(shí)例必須被建立.注意構(gòu)建器的最后兩個(gè)參數(shù).因?yàn)橐l(fā)送一個(gè)包,所以地址和端口必須被給定.一個(gè)applet可能可以知道它的服務(wù)器的地址,但是服務(wù)器如何知道它的客戶機(jī)的地址呢.當(dāng)任何一個(gè)包被收到后,返回的地址和端口會(huì)被解壓出來(lái),并通過(guò)getAddress()和getPort()方法得到.這就是一個(gè)服務(wù)器如何回應(yīng)一個(gè)客戶端的包:
DatagramPacket sendPacket = new DatagramPacket( sendbuf, sendbuf.length,
recvPacket.getAddress(), recvPacket.getPort() );
serverSocket.send( sendPacket );
不像面向連接的操作,數(shù)據(jù)報(bào)服務(wù)器服務(wù)器其實(shí)比數(shù)據(jù)報(bào)客戶端更簡(jiǎn)單:
數(shù)據(jù)報(bào)服務(wù)器
一個(gè)數(shù)據(jù)報(bào)服務(wù)器的基本步驟:
1.在一個(gè)指定的端口上建立一個(gè)數(shù)據(jù)報(bào)socket.
2.用receive方法等待進(jìn)來(lái)的包.
3.用特定的協(xié)議來(lái)回應(yīng)收到的包.
4.回到第二步或繼續(xù)第二步.
5.關(guān)閉數(shù)據(jù)報(bào)socket.
列表9.3演示了一人簡(jiǎn)單的數(shù)據(jù)報(bào)回應(yīng)服務(wù)器.它將回應(yīng)它收到的包.
列表9.3.一個(gè)簡(jiǎn)單的數(shù)據(jù)報(bào)回應(yīng)服務(wù)器
import java.io.*;