java网络编程的应用_Java网络编程之简单的服务端客户端应用实例

本文实例讲述了Java网络编程之简单的服务端客户端应用。分享给大家供大家参考。具体如下&＃xff1a;

在Java中&＃xff0c;我们使用java.net.Socket及其相关类来完成有关网络的相关功能。Socket类非常简单易用&＃xff0c;因为Java技术隐藏了建立网络连接和通过连接发送数据的复杂过程。下面所说的内容只适用于TCP协议。

一、连接到服务器

我们可以使用Socket类的构造函数来打开一个套接字&＃xff0c;如

Socket sk &＃61; new Socket("210.0.235.14",13);

其中&＃xff0c;210.0.235.14是一个点分十进制的String对象&＃xff0c;表示目的主机的IP地址(或主机名), 13表示指定连接目标主机的13端口。这里的210.0.235.14是位于香港的一个授时服务器&＃xff0c;授时服务器默认的端口一般都为13.

注意&＃xff0c;在成功连接到服务器之前&＃xff0c;程序会阻塞。

接下来可以使用Socket类的getInputStream()方法来得到一个InputStream对象&＃xff0c;通过这个对象就可以获取到目标主机给我们发过来的信息&＃xff1a;

InputStream inStream &＃61; sk.getInputStream();

同理&＃xff0c;要向目标主机发送数据&＃xff0c;则可以调用getOutputStream()方法来获取一个输出流对象。

下面的例子功能是连接授时服务器&＃xff0c;并将返回的信息打印到标准输出中&＃xff1a;

try

{

Socket sk &＃61; new Socket("210.0.235.14",13);

sk.setSoTimeout(3000);

InputStream inStream &＃61; sk.getInputStream();

//得到输入流对象

Scanner sc &＃61; new Scanner(inStream);

//将数据打印到控制台

while(sc.hasNextLine())

{

String str &＃61; sc.nextLine();

System.out.println("Output : " &＃43; str);

}

sk.close();

}

catch(SocketTimeoutException e) //超时异常

{

System.out.println("Time Out!");

}

catch(Exception e)

{

e.printStackTrace();

}

代码中setSoTimeout()方法可以设置超时时间&＃xff0c;即如果超过了设定时间还没有完成读写操作&＃xff0c;则会抛出SocketTimeoutException&＃xff0c;可以通过捕获这个异常来关闭连接。

另外还有一个超时问题是必须要解决的&＃xff0c;就是这个Socket类的构造函数

new Socket(host,port);

会一直无限地阻塞下去&＃xff0c;直到成功建立了到目标主机的连接为止。这当然不是我们所希望的。我们可以通过如下调用方式解决此问题&＃xff1a;

Socket sk &＃61; new Socker();

sk.connect(new InetSocketAddress(host,port),2000);

//设置超时时间为2秒

二、获取主机地址

InetAddress类的静态方法getByName(hostname)可以返回代表了某个主机地址的InetAddress对象&＃xff0c;这个对象封闭了一个4字节的序列&＃xff0c;即主机的IP地址。然后再调用getHostAddress()方法返回一个表示IP地址的String对象.

一些访问量大的主机名通常会对应着多个IP地址以实现负载均衡。我们可以调用getAllByName()方法来获得所有主机地址&＃xff0c;该方法返回一个InetAddress对象的数组。

下面是一个简单的小程序&＃xff0c;实现的功能是&＃xff0c;如果不在命令行中设置参数&＃xff0c;就打印出本地的IP地址&＃xff0c;如果指定了主机名&＃xff0c;则打印出该主机所有的IP地址&＃xff1a;

package cls;

import java.net.*;

public class ShowIP

{

public static void main(String[] args)

{

try

{

if(args.length > 0)

{

String hostName &＃61; args[0]; //主机名

InetAddress[] addr &＃61; InetAddress.getAllByName(hostName);

//得到该主机的所有地址

//打印输出至控制台

for(InetAddress address : addr)

{

System.out.println(address.getHostAddress());

}

}

else

{

System.out.println(InetAddress.getLocalHost().getHostAddress());

}

}

catch(Exception e)

{

e.printStackTrace();

}

}

}

三、服务器端程序

服务器端应用程序使用ServerSocket类来创建套接字&＃xff0c;并钭其绑定至本地端口中&＃xff0c;如

ServerSocket sock &＃61; new ServerSocker(8000);

sock.accept()方法让程序不停地等待连接&＃xff0c;该方法只有当有客户端连接时才会返回一个代表了新连接的Socket对象&＃xff0c;即该方法会发生阻塞。

这里一般要为每个连接新开启一个线程为其服务。

下面是一个完整的例子&＃xff0c;服务端在8400端口处等待连接&＃xff0c;每当连接到来时&＃xff0c;新开一个线程为其服务&＃xff0c;并将连接信息写入的日志文件中:

package cls;

import java.io.*;

import java.net.*;

import java.util.*;

public class ServerDemo

{

/**

* &＃64;param args

*/

public static void main(String[] args)

{

try

{

//ServerSocket servSocket &＃61; new ServerSocket(8000);

ServerSocket servSocket &＃61; new ServerSocket(8400);

int amount &＃61; 0;

while(true)

{

Socket client &＃61; servSocket.accept();

&＃43;&＃43;amount;

Date time &＃61; new Date();

String prompt &＃61; time.toString() &＃43; ": 第" &＃43; amount &＃43; "个用户 " &＃43; client.getInetAddress().getHostAddress() &＃43; " 已连接\n";

System.out.print(prompt); //在控制台输出信息

ServerDemo.writeLog(prompt); //写入到文件中

//start a new Thread

Thread th &＃61; new Thread(new ServThread(client,amount));

th.start();

}

}

catch(Exception e)

{

e.printStackTrace();

}

}

//写入日志文件

public static void writeLog(String str)

{

File logFile &＃61; new File("server-log.txt");

try

{

FileWriter out &＃61; new FileWriter(logFile,true);

out.append(str);

out.close();

}

catch(Exception e)

{

e.printStackTrace();

}

}

}

/*

* 服务线程类

*/

class ServThread implements Runnable

{

private Socket client;

private int ix;

public ServThread(Socket soc,int ix)

{

client &＃61; soc;

this.ix &＃61; ix;

}

public void run()

{

try

{

InputStream inStream &＃61; client.getInputStream();

OutputStream outStream &＃61; client.getOutputStream();

Scanner recv &＃61; new Scanner(inStream);

PrintWriter send &＃61; new PrintWriter(outStream,true);

send.println("欢迎&＃xff5e;随便聊几句吧&＃xff01;[输入&＃39;bye&＃39;关闭联接]");

while(recv.hasNextLine())

{

String str &＃61; recv.nextLine();

if(str.equals("bye"))

{

send.println("See you later ~ ^-^");

break;

}

send.println("这是个测试程序&＃xff0c;现在还没有什么功能哦");

}

Date time &＃61; new Date();

String prompt &＃61; time.toString() &＃43; ": 第" &＃43; ix &＃43; "个用户 " &＃43; client.getInetAddress().getHostAddress() &＃43; " 已断开连接\n";

System.out.print(prompt);

ServerDemo.writeLog(prompt); //写入到文件中

client.close();

}

catch(Exception e)

{

e.printStackTrace();

}

}

}

这个程序已经被放到了服务器上&＃xff0c;大家可以使用telnet youthol.tk 8400 命令来体验一下这个程序的运行结果

希望本文所述对大家的java程序设计有所帮助。