Java網絡編程-Java Socket編程(四)

發表于:2007-05-25來源:作者:點擊數: 標簽:java編程Socket-Java網絡編程
重復和并發 服務器 這個應用程序被當作一個重復的服務器.因為它只有在處理完一個進程以后才會接受另一 個連接.更多的復雜服務器是并發的.它為每一個請求分配一個線程,而不是來一個處理一 個.所以看起來它在同時處理多人請求.所有的商業的服務器都是并發的服

重復和并發服務器
這個應用程序被當作一個重復的服務器.因為它只有在處理完一個進程以后才會接受另一
個連接.更多的復雜服務器是并發的.它為每一個請求分配一個線程,而不是來一個處理一
個.所以看起來它在同時處理多人請求.所有的商業的服務器都是并發的服務器.
Java數據報類
不像面向連接的類,數據報的客戶端和服務器端的類在表面上是一樣的.下面的程序建立
了一個客戶和服務器商的數據報sockets:
DatagramSocket serverSocket = new DatagramSocket( 4545 );
DatagramSocket clientSocket = new DatagramSocket();
服務器用參數4545來指定端口號,由于客戶端將要呼叫服務器,客戶端可以利用可利用的
端口.如果省略第二個參數,程序會讓操作系統分配一個可用的端口.客戶端可以請求一個
指定的端口,但是如果其它的應用程序已經綁定到這個端口之上,請求將會失敗.如果你的
意圖不是作為一個服務器,最好不要指定端口.
由于流不能由交談得到,那么我么如何與一個數據報Socket進行對話.答案在于數據報類
.
接收數據報
DatagramPacket類是用來通過DatagramSocket類接收和發送數據的類.packet類包括了連
接信息和數據.就如前面所說的一樣,數據報是自身獨立的傳輸單元.DatagramPacket類壓
縮了這些單元.下面的程序表示了用一個數據報socket來接收數據:
DatagramPacket packet = new DatagramPacket(new byte[512], 512); clientSocket
.receive(packet);
clientSocket.receive(packet);
packet的構建器需要知道將得到的數據放在哪兒.一個512字節的緩存被建立并且作為構
建器的第二個參數.每二個構建器參數是緩存的大小.就像ServerSocket類的aclearcase/" target="_blank" >ccept()方
法一樣,receive()方法在數據可用之前將會阻塞.
發送數據報
發送數據報是非常地簡單地,所有需要的只是一個地址.地址是由InetAddress類來建立的
.這個類沒有公共的構建器,但是它有幾個static的方法,可以用來建立這個類的實例.下
面的列表列出了建立InetAddress類的實例的方法:
Public InetAddress Creation Methods
InetAddress getByName(String host);
InetAddress[] getAllByName(String host);
InetAddress getLocalHost();
得到本地主機的地址是非常地有用的,只有前面兩個方法是用來發送數據包的.getByNam
e()和getAllByName()需要目的主機的地址.第一個方法僅僅只是返回第一個符合條件的
東西.第二個方法是必須的,因為一臺計算機可能有多個地址.在這種情況下,這臺計算機
被稱為multi-homed.
所有的建立的方法都被標記為static.它們必須像下面這樣得到調用:
InetAddress addr1 = InetAddress.getByName("merlin");
InetAddress addr2[] = InetAddress.getAllByName("merlin");
InetAddress addr3 = InetAddress.getLocalHost();

 

重復和并發服務器
所有的這些調用都可以擲出一個UnknownHostException違例.如果一臺計算機沒有連接上
DNS服務器,或者主機的確沒有找到,這個違例就會被擲出.如果一臺計算機沒有一個激活
的TCP/IP配置,getLocalHost()也為失敗并擲出一個違例.
一旦一個地址被確定了,數據報就可以被送出了.下面的程序傳輸了一個字符串給目的so
cket:
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 );
首先,字符串必須被轉換成一個字節數組.然后,一個新的DatagramPacket實例必須被建立
.注意構建器的最后兩個參數.因為要發送一個包,所以地址和端口必須被給定.一個appl
et可能可以知道它的服務器的地址,但是服務器如何知道它的客戶機的地址呢.當任何一
個包被收到后,返回的地址和端口會被解壓出來,并通過getAddress()和getPort()方法得
到.這就是一個服務器如何回應一個客戶端的包:
DatagramPacket sendPacket = new DatagramPacket( sendbuf, sendbuf.length,
recvPacket.getAddress(), recvPacket.getPort() );
serverSocket.send( sendPacket );
不像面向連接的操作,數據報服務器服務器其實比數據報客戶端更簡單:
數據報服務器
一個數據報服務器的基本步驟:
1.在一個指定的端口上建立一個數據報socket.
2.用receive方法等待進來的包.
3.用特定的協議來回應收到的包.
4.回到第二步或繼續第二步.
5.關閉數據報socket.
列表9.3演示了一人簡單的數據報回應服務器.它將回應它收到的包.
列表9.3.一個簡單的數據報回應服務器
import java.io.*;
import java.net.*;
public class SimpleDatagramServer
{
public static void main(String[] args)
{
DatagramSocket socket = null;
DatagramPacket recvPacket, sendPacket;
try
{
socket = new DatagramSocket(4545);
while (socket != null)
{
recvPacket= new DatagramPacket(new byte[512], 512);
socket.receive(recvPacket);
sendPacket = new DatagramPacket(
recvPacket.getData(), recvPacket.getLength(),
recvPacket.getAddress(), recvPacket.getPort() );
socket.send( sendPacket );
}
}
catch (SocketException se)
{
System.out.println("Error in SimpleDatagramServer: " + se);
}
catch (IOException ioe)
{
System.out.println("Error in SimpleDatagramServer: " + ioe);


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

評論列表(網友評論僅供網友表達個人看法,并不表明本站同意其觀點或證實其描述)
国产97人人超碰caoprom_尤物国产在线一区手机播放_精品国产一区二区三_色天使久久综合给合久久97