新闻中心

EEPW首页 > 嵌入式系统 > 设计应用 > 基于socket的Java网络编程集粹

基于socket的Java网络编程集粹

作者:时间:2012-05-04来源:网络收藏

事实上简单的理解就是两台计算机相互通讯数据而已,对于程序员而言,去掌握一种编程接口并使用一种编程模型相对就会显得简单的多了,SDK提供一些相对简单的Api来完成这些工作。Socket就是其中之一,对于而言,这些Api存在与java.net这个包里面,因此只要导入这个包就可以准备了。

本文引用地址:http://www.eepw.com.cn/article/149139.htm

的基本模型就是客户机到服务器模型,简单的说就是两个进程之间相互通讯,然后其中一个必须提供一个固定的位置,而另一个则只需要知道这个固定的位置。并去建立两者之间的联系,然后完成数据的通讯就可以了,这里提供固定位置的通常称为服务器,而建立联系的通常叫做客户端,这个简单的模型,就可以进入网络编程啦。

对这个模型的支持有很多种Api,而这里我只想介绍有关Socket的编程接口,对于Java而言已经简化了Socket的编程接口。首先我们来讨论有关提供固定位置的服务方是如何建立的。Java提供了ServerSocket来对其进行支持.事实上当你创建该类的一个实力对象并提供一个端口资源你就建立了一个固定位置可以让其他计算机来访问你,ServerSocketserver=newServerSocket(6789);这里稍微要注意的是端口的分配必须是唯一的。因为端口是为了唯一标识每台计算机唯一服务的,另外端口号是从0~65535之间的,前1024个端口已经被Tcp/Ip作为保留端口,因此你所分配的端口只能是1024个之后的。好了,我们有了固定位置.现在所需要的就是一根连接线了.该连接线由客户方首先提出要求。因此Java同样提供了一个Socket对象来对其进行支持,只要客户方创建一个Socket的实例对象进行支持就可以了。Socketclient=newSocket(InetAddress.getLocalHost(),5678);客户机必须知道有关服务器的IP地址,对于着一点Java也提供了一个相关的类InetAddress该对象的实例必须通过它的静态方法来提供,它的静态方法主要提供了得到本机IP和通过名字或IP直接得到InetAddress的方法。

上面的方法基本可以建立一条连线让两台计算机相互交流了,可是数据是如何传输的呢?事实上I/O操作总是和网络编程息息相关的。因为底层的网络是继续数据的,除非远程调用,处理问题的核心在执行上,否则数据的交互还是依赖于IO操作的,所以你也必须导入java.io这个包.java的IO操作也不复杂,它提供了针对于字节流和Unicode的读者和写者,然后也提供了一个缓冲用于数据的读写。

BufferedReaderin=newBufferedReader(newInputStreamReader(server.getInputStream()));

PrintWriterout=newPrintWriter(server.getOutputStream());

上面两句就是建立缓冲并把原始的字节流转变为Unicode可以操作,而原始的字节流来源于Socket的两个方法,getInputStream()和getOutputStream()方,分别用来得到输入和输出,那么现在有了基本的模型和基本的操作工具,我们可以做一个简单的Socket例程了。

服务方:

importjava.io.*;

importjava.net.*;

publicclassMyServer{

publicstaticvoidmain(String[]args)throwsIOException{

ServerSocketserver=newServerSocket(5678);

Socketclient=server.accept();

BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

PrintWriterout=newPrintWriter(client.getOutputStream());

while(true){

Stringstr=in.readLine();

System.out.println(str);

out.println(hasreceive....);

out.flush();

if(str.equals(end))

break;

}

client.close();

}

}

这个程序的主要目的在于服务器不断接收客户机所写入的信息只到,客户机发送End字符串就退出程序,并且服务器也会做出Receive为回应,告知客户机已接收到消息。

客户机代码:

importjava.net.*;

importjava.io.*;

publicclassClient{

staticSocketserver;

publicstaticvoidmain(String[]args)throwsException{

server=newSocket(InetAddress.getLocalHost(),5678);

BufferedReaderin=newBufferedReader(newInputStreamReader(server.getInputStream()));

PrintWriterout=newPrintWriter(server.getOutputStream());

BufferedReaderwt=newBufferedReader(newInputStreamReader(System.in));

while(true){

Stringstr=wt.readLine();

out.println(str);

out.flush();

if(str.equals(end)){

break;

}

System.out.println(in.readLine());

}

server.close();

}

}

客户机代码则是接受客户键盘输入,并把该信息输出,然后输出End用来做退出标识。

这个程序只是简单的两台计算机之间的通讯,如果是多个客户同时访问一个服务器呢?你可以试着再运行一个客户端,结果是会抛出异常的。那么多个客户端如何实现呢?

其实,简单的分析一下,就可以看出客户和服务通讯的主要通道就是Socket本身,而服务器通过accept方法就是同意和客户建立通讯.这样当客户建立Socket的同时。服务器也会使用这一根连线来先后通讯,那么既然如此只要我们存在多条连线就可以了。那么我们的程序可以变为如下:

服务器:

importjava.io.*;

importjava.net.*;

publicclassMyServer{

publicstaticvoidmain(String[]args)throwsIOException{

ServerSocketserver=newServerSocket(5678);

while(true){

Socketclient=server.accept();

BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

PrintWriterout=newPrintWriter(client.getOutputStream());

while(true){

Stringstr=in.readLine();

System.out.println(str);

out.println(hasreceive....);

out.flush();


上一页 1 2 下一页

评论


相关推荐

技术专区

关闭