java网络编程之socket网络编程示例(服务器端/客户端)

Java为TCP协议提供了两个类,分别在客户端编程和服务器端编程中使用它们。在应用程序开始通信之前,需要先创建一个连接,由客户端程序发起;而服务器端的程序需要一直监听着主机的特定端口号,等待客户端的连接。在客户端中我们只需要使用Socket实例,而服务端要同时处理ServerSocket实例和Socket实例;二者并且都使用OutputStream和InpuStream来发送和接收数据。

学习一种知识最好的方式就是使用它,通过前面的笔记,我们已经知道如何获取主机的地址信息,现在我们通过一个简单的程序来初步学习传输层使用了TCP协议的Socket编程。

TCP服务器端

在Socket编程中,服务器端远比客户端要复杂得多。服务器端的工作就是建立一个通信终端,被动的等待客户端的连接。下面这个服务器端程序的示例的作用是:监听从控制台输入获取的端口号,并且将客户端发送过来的消息,再发送回去。

代码如下:
importjava.net.*;importjava.text.MessageFormat;importjava.io.*;

publicclassTCPEchoServer{

privatestaticfinalintBUFSIZE=32;

publicstaticvoidmain(String[]args)throwsIOException{//TODOAuto-generatedmethodstub    //从控制台获取需要监听的端口号if(args.length!=1)thrownewIllegalArgumentException("Parameter(s):<Port>");//获取端口号intservPort=Integer.parseInt(args[0]);//实例化一个ServerSocket对象实例ServerSocketservSocket=newServerSocket(servPort);System.out.println(MessageFormat.format("开始启动监听,端口号:{0}",args[0]));

//初始接收数据的总字节数intrecvMsgSize;//接收数据的缓冲区byte[]receiveBuf=newbyte[BUFSIZE];

//循环迭代,监听端口号,处理新的连接请求while(true){//阻塞等待,每接收到一个请求就创建一个新的连接实例SocketclntSocket=servSocket.accept();//获取连接的客户端的SocketAddressSocketAddressclientAddress=clntSocket.getRemoteSocketAddress();//打印输出连接客户端地址信息System.out.println("Handlingclientat"+clientAddress);//从客户端接收数据的对象InputStreamin=clntSocket.getInputStream();//向客户端发送数据的对象OutputStreamout=clntSocket.getOutputStream();//读取客户端发送的数据后,再发送到客户端while((recvMsgSize=in.read(receiveBuf))!=-1){out.write(receiveBuf,0,recvMsgSize);}//客户端关闭连接时,关闭连接System.out.println("客户端关闭连接");clntSocket.close();}}}

TCP客户端在Socket编程中,首先客户端需要向服务器端发送,然后被动的等待服务器端的响应。下面的示例中:我们向服务器端发送信息,等待服务器端发送的消息,并打印显示出来。 

代码如下:
importjava.io.*;importjava.net.Socket;importjava.net.SocketException;

publicclassTCPEchoClient{publicstaticvoidmain(String[]args)throwsIOException{//TODOAuto-generatedmethodstub    //判断从控制台接受的参数是否正确if((args.length<2)||(args.length>3))thrownewIllegalArgumentException("Parameter(s):<Server><Word>[<Port>]]");//获取服务器地址Stringserver=args[0];//获取需要发送的信息byte[]data=args[1].getBytes();//如果有三个从参数那么就获取发送信息的端口号,默认端口号为8099intservPort=(args.length==3)?Integer.parseInt(args[2]):8099;//根据服务器地址和端口号实例化一个Socket实例Socketsocket=newSocket(server,servPort);System.out.println("Connectedtoserver...sendingechostring");//返回此套接字的输入流,即从服务器接受的数据对象InputStreamin=socket.getInputStream();//返回此套接字的输出流,即向服务器发送的数据对象OutputStreamout=socket.getOutputStream();//向服务器发送从控制台接收的数据out.write(data);//接收数据的计数器,将写入数据的初始偏移量inttotalBytesRcvd=0;//初始化接收数据的总字节数intbytesRcvd;while(totalBytesRcvd<data.length){//服务器关闭连接,则返回-1,read方法返回接收数据的总字节数if((bytesRcvd=in.read(data,totalBytesRcvd,data.length-totalBytesRcvd))==-1)thrownewSocketException("与服务器的连接已关闭");totalBytesRcvd+=bytesRcvd;}//打印服务器发送来的数据System.out.println("Received:"+newString(data));//关闭连接socket.close();}}

首先运行服务器端,监听8099端口:

接着运行客户端程序,并且向服务器端发送消息:

再次查看我们的服务器端控制台,我们可以看到前面客户端连接的地址信息:

以上是 java网络编程之socket网络编程示例(服务器端/客户端) 的全部内容, 来源链接: utcz.com/p/206986.html

回到顶部