当前位置: 移动技术网 > IT编程>开发语言>Java > java网络编程之socket网络编程示例(服务器端/客户端)

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

2019年07月22日  | 移动技术网IT编程  | 我要评论

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();
//获取连接的客户端的socketaddress
socketaddressclientaddress=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();
//如果有三个从参数那么就获取发送信息的端口号,默认端口号为8099
intservport=(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端口:

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

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

如对本文有疑问, 点击进行留言回复!!

相关文章:

验证码:
移动技术网