1. client/server networking
java通过socket来完成它所有的网络底层的通讯,socket是一种通讯的通道,通过它可以将数据通过特定的端中发送及接收。java中的socket可以分成二大类:
(1) datagram sockets:数据包socket;
(2) stream sockets:流socket;
1.2 datagram socket
datagram socket使用udp来实现数据通讯,因此它不能保证数据能够到达目的地,但是由于它不需要专用的网络链接,所以它所需的资源相对少的多。
datagram以包的方式发送数据,但它不能保证这些数据包以特定的顺序到达目的,因此包中往往需要包含序列号的信息,接收方可以根据序列号的信息决定是否所有的包都已收到,并按正常顺序重组这些包。
java通过两个类datagramsocket和datagrampacket来支持datagram socket。datagramsocket实现了datagram socket的基本功能,而datagrampacket则提供了对包的一些支持。
datagramsocket的几个重要方法:
(1) datagramsocket():随机绑定一个有效的端口;
(2) datagramsocket(int port):绑定指定的端口;
(3) void send(datagrampacket p):发送数据报,由于目的地的地址信息已包含在数据报中,所以不需要在本函数中提供地址信息;
(4) synchronized void receive(datagrampacket p):接收数据包,线程安全;
(5) synchronized void close():关闭socket;
在datagramsocket中并不区分serversocket和clientsocket,如果一定要区分,那么发送的是client,而接收的是server。
datagrampacket有以几个重要的方法:
(1) datagrampacket(byte ibuf[], int ilength):用于接收数据报;
(2) datagrampacket(byte ibuf[], int ilength, inetaddressiaddr, int iport):用于发送的数据报;
(3) byte[] getdata()
(4) int getlength()
以下是完整的datagram socket的例子:
接收端,server端代码:
import java.io.*;
import java.net.*;
class fortuneserver1 extends thread
{
datagramsocket serversocket;
public fortuneserver1()
{
super("fortuneserver1");
try
{
serversocket = new datagramsocket(1114);
system.out.println("fortuneserver up and running...");
}
catch (socketexception e)
{
system.err.println("exception: couldn't create datagram socket");
system.exit(1);
} }
public static void main(string[] args)
{
fortuneserver1 server = new fortuneserver1();
server.start();
}
public void run()
{
if (serversocket == null)
return;
while (true)
{
try
{
inetaddress address;
int port;
datagrampacket packet;
byte[] data = new byte[256];
int num = 1;
packet = new datagrampacket(data, data.length);
serversocket.receive(packet);
address = packet.getaddress();
port = packet.getport();
file infile = new file("fortunes.txt");
fileinputstream instream = new fileinputstream(infile);
if (instream.read(data) <= 0)
{
system.err.println("error: couldn't read fortunes");
}
packet = new datagrampacket(data, data.length, address, port);
serversocket.send(packet);
}
catch (exception e)
{
system.err.println("exception: " + e);
e.printstacktrace();
} } } }
说明:
(1) 这个例子中接收端的socket使用了多线程,多线程的概念可以参考本文的多线程部分;
(2) 在构造函数中创建了datagramsocket,并且使用了1114这个端口;
(3) 本例子的关键函数是run,它使用了死循环,在循环中使用了receive这方法来临听1114端口,如果1114端口没有请求数据到来,那么这个程序就一直停留在receive这个位置,不再往下执行;
(4) 当1114端有数据时,receive方法将接收到的datagrampacket数据包放在packet这个对象中,然后解析其中的数据,获取发送方的地址信息;
(5) 然后再创建datagrampacket包,并填充数据,发送到原接收端。
以下是发送端的代码:
import java.io.*;
import java.net.*;
class fortuneclient
{
public static void main(string args[])
{
fortuneclient client = new fortuneclient();
system.out.println(client.getmessage());
}
public string getmessage()
{
string fortune;
try {
datagramsocket socket;
datagrampacket packet;
byte[] data = new byte[256];
socket = new datagramsocket();
packet = new datagrampacket(data, data.length,inetaddress.getbyname("127.0.0.1"), 1114);
socket.send(packet);
packet = new datagrampacket(data, data.length);
socket.receive(packet);
fortune = new string(packet.getdata(), 0);
socket.close();
}
catch (unknownhostexception e) {
system.err.println("exception: host could not be found");
return null;
}
catch (exception e) {
system.err.println("exception: " + e);
e.printstacktrace();
return null;
}
return fortune;
} }
客户端的代码与服务器端的代码基本相同,只是没有了循环,并且处理步骤与服务器端的基本相反。这也说明了datagram socket不真正区分server和client。
1.3 stream socket
stream socket与datagram socket不同,它有一个永久性的链接,可以确保数据可靠的发送到对方。但是stream socket所占的资源更多。
java主要通过socket及serversocket来实现stream socket,一个用于客户端,另一个用户服务器端。
socket类的几个重要方法如下:
(1) socket(string host, int port)
(2) socket(inetaddress address, int port)
(3) synchronized void close()
(4) inputstream getinputstream()
(5) outputstream getoutputstream()
可以看出stream socket中的socket与datagram socket中的socket的区别:
(1) 在构造函数中,这里需要指定服务器的地址与端口,用于它发送数据之前建立链接,而datagram的socket不需要建立链接,它仅需要在要发送的数据包中包含地址信息即可;
(2) stream socket的两个重要方法和其它流的方法类似,而且在操作上也相似,其实在操作stream socket时,只要建立了链接,那么以后的操作和流的操作一样了,你可以忘了你在操作socket,只当做自己在操作普通的流。
serversocket有以下几个重要的方法:
(1) serversocket(int port):监听指定端口,监听时间为默认值50;
(2) serversocket(int port, int count):监听指定端口,并指定监听时间;
(3) serversocket(int port, int backlog, inetaddress bindaddr):只接收指定接口发过来的数据;
(4) socket accept():accpet方法会返回一个socket对象,使用该socket对象的getinputstream及getoutputstream方法获取输入及输出流。由此可见无论是服务器端还是客户端,它们都是通过socket对象来收发数据的。程序执行到accpet时会进入监听状态,不再向下执行一直到接收到数据。
(5) void close()
闽公网安备 35060202000074号