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

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