Java网络编程之简单的服务端客户端应用实例
本文实例讲述了Java网络编程之简单的服务端客户端应用。分享给大家供大家参考。具体如下：
在Java中，我们使用java.net.Socket及其相关类来完成有关网络的相关功能。Socket类非常简单易用，因为Java技术隐藏了建立网络连接和通过连接发送数据的复杂过程。下面所说的内容只适用于TCP协议。
一、连接到服务器
我们可以使用Socket类的构造函数来打开一个套接字，如
Socketsk=newSocket("210.0.235.14",13);
其中，210.0.235.14是一个点分十进制的String对象，表示目的主机的IP地址(或主机名),13表示指定连接目标主机的13端口。这里的210.0.235.14是位于香港的一个授时服务器，授时服务器默认的端口一般都为13.
注意，在成功连接到服务器之前，程序会阻塞。
接下来可以使用Socket类的getInputStream()方法来得到一个InputStream对象，通过这个对象就可以获取到目标主机给我们发过来的信息：
InputStreaminStream=sk.getInputStream();
同理，要向目标主机发送数据，则可以调用getOutputStream()方法来获取一个输出流对象。
下面的例子功能是连接授时服务器，并将返回的信息打印到标准输出中：
try
{
Socketsk=newSocket("210.0.235.14",13);
sk.setSoTimeout(3000);
InputStreaminStream=sk.getInputStream();
//得到输入流对象
Scannersc=newScanner(inStream);
//将数据打印到控制台
while(sc.hasNextLine())
{
Stringstr=sc.nextLine();
System.out.println("Output:"+str);
}
sk.close();
}
catch(SocketTimeoutExceptione)//超时异常
{
System.out.println("TimeOut!");
}
catch(Exceptione)
{
e.printStackTrace();
}
代码中setSoTimeout()方法可以设置超时时间，即如果超过了设定时间还没有完成读写操作，则会抛出SocketTimeoutException，可以通过捕获这个异常来关闭连接。
另外还有一个超时问题是必须要解决的，就是这个Socket类的构造函数
newSocket(host,port);
会一直无限地阻塞下去，直到成功建立了到目标主机的连接为止。这当然不是我们所希望的。我们可以通过如下调用方式解决此问题：
Socketsk=newSocker(); sk.connect(newInetSocketAddress(host,port),2000); //设置超时时间为2秒
二、获取主机地址
InetAddress类的静态方法getByName(hostname)可以返回代表了某个主机地址的InetAddress对象，这个对象封闭了一个4字节的序列，即主机的IP地址。然后再调用getHostAddress()方法返回一个表示IP地址的String对象.
一些访问量大的主机名通常会对应着多个IP地址以实现负载均衡。我们可以调用getAllByName()方法来获得所有主机地址，该方法返回一个InetAddress对象的数组。
下面是一个简单的小程序，实现的功能是，如果不在命令行中设置参数，就打印出本地的IP地址，如果指定了主机名，则打印出该主机所有的IP地址：
packagecls;
importjava.net.*;
publicclassShowIP
{
publicstaticvoidmain(String[]args)
{
try
{
if(args.length>0)
{
StringhostName=args[0];//主机名
InetAddress[]addr=InetAddress.getAllByName(hostName);
//得到该主机的所有地址
//打印输出至控制台
for(InetAddressaddress:addr)
{
System.out.println(address.getHostAddress());
}
}
else
{
System.out.println(InetAddress.getLocalHost().getHostAddress());
}
}
catch(Exceptione)
{
e.printStackTrace();
}
}
}
三、服务器端程序
服务器端应用程序使用ServerSocket类来创建套接字，并钭其绑定至本地端口中，如
ServerSocketsock=newServerSocker(8000);
sock.accept()方法让程序不停地等待连接，该方法只有当有客户端连接时才会返回一个代表了新连接的Socket对象，即该方法会发生阻塞。
这里一般要为每个连接新开启一个线程为其服务。
下面是一个完整的例子，服务端在8400端口处等待连接，每当连接到来时，新开一个线程为其服务，并将连接信息写入的日志文件中:
packagecls;
importjava.io.*;
importjava.net.*;
importjava.util.*;
publicclassServerDemo
{
/**
*@paramargs
*/
publicstaticvoidmain(String[]args)
{
try
{
//ServerSocketservSocket=newServerSocket(8000);
ServerSocketservSocket=newServerSocket(8400);
intamount=0;
while(true)
{
Socketclient=servSocket.accept();
++amount;
Datetime=newDate();
Stringprompt=time.toString()+":第"+amount+"个用户"+client.getInetAddress().getHostAddress()+"已连接\n";
System.out.print(prompt);//在控制台输出信息
ServerDemo.writeLog(prompt);//写入到文件中
//startanewThread
Threadth=newThread(newServThread(client,amount));
th.start();
}
}
catch(Exceptione)
{
e.printStackTrace();
}
}
//写入日志文件
publicstaticvoidwriteLog(Stringstr)
{
FilelogFile=newFile("server-log.txt");
try
{
FileWriterout=newFileWriter(logFile,true);
out.append(str);
out.close();
}
catch(Exceptione)
{
e.printStackTrace();
}
}
}
/*
*服务线程类
*/
classServThreadimplementsRunnable
{
privateSocketclient;
privateintix;
publicServThread(Socketsoc,intix)
{
client=soc;
this.ix=ix;
}
publicvoidrun()
{
try
{
InputStreaminStream=client.getInputStream();
OutputStreamoutStream=client.getOutputStream();
Scannerrecv=newScanner(inStream);
PrintWritersend=newPrintWriter(outStream,true);
send.println("欢迎～随便聊几句吧！[输入'bye'关闭联接]");
while(recv.hasNextLine())
{
Stringstr=recv.nextLine();
if(str.equals("bye"))
{
send.println("Seeyoulater~^-^");
break;
}
send.println("这是个测试程序，现在还没有什么功能哦");
}
Datetime=newDate();
Stringprompt=time.toString()+":第"+ix+"个用户"+client.getInetAddress().getHostAddress()+"已断开连接\n";
System.out.print(prompt);
ServerDemo.writeLog(prompt);//写入到文件中
client.close();
}
catch(Exceptione)
{
e.printStackTrace();
}
}
}
这个程序已经被放到了服务器上，大家可以使用telnetyouthol.tk8400命令来体验一下这个程序的运行结果
希望本文所述对大家的java程序设计有所帮助。