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

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();
}
}
}

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();
}
}