java 中模拟TCP传输的客户端和服务端实例详解
一、创建TCP传输的客户端
1、建立TCP客户端的Socket服务,使用的是Socket对象,建议该对象一创建就明确目的地,即要连接的主机;
2、如果连接建立成功,说明数据传输通道已建立,该通道就是Socket流,是底层建立好的,既然是流,说着这里既有输入流,又有输出流,想要输入流或者输出流对象,可以通过Socket来获取,可以通过getOutputStream()和getInputStream()来获取;
3、使用输出流,将数据写出;
4、关闭Socket服务。
importjava.io.IOException; importjava.io.OutputStream; importjava.net.Socket; publicclassClient{ publicstaticvoidmain(String[]args)throwsIOException{ //1、创建客户端的Socket服务 Socketsocket=newSocket("192.168.1.100",10002); //2、获取Socket流中输入流 OutputStreamout=socket.getOutputStream(); //3、使用输出流将指定的数据写出去 out.write("TCPiscoming!".getBytes()); //4、关闭Socket服务 socket.close(); } }
二、创建TCP传输的服务端
1、建立TCP服务端的的Socket服务,通过ServerSocket对象;
2、服务端必须对外提供一个端口,否则客户端无法连接;
3、获取连接过来的客户端对象;
4、通过客户端对象来获取Socket流,读取客户端发来的数据;
5、关闭资源,关客户端,关服务端。
importjava.io.IOException; importjava.io.InputStream; importjava.net.ServerSocket; importjava.net.Socket; publicclassServer{ publicstaticvoidmain(String[]args)throwsIOException{ //1、创建客户端对象 ServerSocketss=newServerSocket(10002); //2、获取连接过来的客户端对象 Sockets=ss.accept(); Stringip=s.getInetAddress().getHostAddress(); //3、通过Socket对象获取输入流,读取客户端发来的数据 InputStreamin=s.getInputStream(); byte[]buf=newbyte[1024]; intlen=in.read(buf); Stringtext=newString(buf,0,len); System.out.println(ip+":"+text); //4、关闭资源 s.close(); ss.close(); } }
三、优化TCP传输的客户端和服务端
在本部分,我们对前两部分的内容进行优化,实现TCP传输模式下的客户端和服务端的交互功能。
/** *优化TCP传输的客户端 */ importjava.io.IOException; importjava.io.InputStream; importjava.io.OutputStream; importjava.net.Socket; publicclassClientUpdate{ publicstaticvoidmain(String[]args)throwsIOException{ Socketsocket=newSocket("192.168.1.100",10002); OutputStreamout=socket.getOutputStream(); out.write("tcp!".getBytes()); //读取服务端返回的数据,使用Socket读取流 InputStreamin=socket.getInputStream(); byte[]buf=newbyte[1024]; intlen=in.read(buf); Stringtext=newString(buf,0,len); System.out.println(text); socket.close(); } }
/** *优化TCP传输的服务端 */ importjava.io.IOException; importjava.io.InputStream; importjava.io.OutputStream; importjava.net.ServerSocket; importjava.net.Socket; publicclassServerUpdate{ publicstaticvoidmain(String[]args)throwsIOException{ //1、创建服务端对象 ServerSocketss=newServerSocket(10002); //2、获取连接过来的客户端对象 Sockets=ss.accept();//accept方式为阻塞式方法 Stringip=s.getInetAddress().getHostAddress(); //3、通过Socket对象获取输入流,要读取客户端发来的数据 InputStreamin=s.getInputStream(); byte[]buf=newbyte[1024]; intlen=in.read(buf); Stringtext=newString(buf,0,len); System.out.println(ip+":"+text); //使用客户端的Socket对象的输出流给客户端返回数据 OutputStreamout=s.getOutputStream(); out.write("收到".getBytes()); s.close(); ss.close(); } }
四、创建英文大写转换服务器
应用TCP(TransmissionControlProtocol,传输控制协议)的相关性质,创建一个基于TCP传输下的英文大写转换服务器,要求:客户端输入字母数据,发送给服务端;服务端收到数据后显示在控制台,并将该数据转成大写字母返回给客户端;直到客户端输入“over”为止,转换结束。
importjava.io.BufferedReader; importjava.io.IOException; importjava.io.InputStreamReader; importjava.io.PrintWriter; importjava.net.Socket; publicclassTransClient{ publicstaticvoidmain(String[]args)throwsIOException{ /** *思路:创建客户端 *1、创建Socket客户端对象 *2、获取键盘录入的数据 *3、将录入的信息发送给Socket输出流 *4、读取服务端的数据并返回的大写数据 */ //1、创建Socket客户端对象 Sockets=newSocket("192.168.1.100",10004); //2、获取键盘录入 BufferedReaderbufr=newBufferedReader(newInputStreamReader(System.in)); //3、Socket输出流 PrintWriterout=newPrintWriter(s.getOutputStream(),true); //4、Socket输入流,读取服务端的数据并返回的大写数据 BufferedReaderbufIn=newBufferedReader(newInputStreamReader(s.getInputStream())); Stringline=null; while((line=bufr.readLine())!=null){ if("over".equals(line)) break; out.println(line); //读取服务端返回的一行大写数据 StringupperStr=bufIn.readLine(); System.out.println(upperStr); } s.close(); } }
importjava.io.BufferedReader; importjava.io.IOException; importjava.io.InputStreamReader; importjava.io.PrintWriter; importjava.net.ServerSocket; importjava.net.Socket; publicclassTransServer{ publicstaticvoidmain(String[]args)throwsIOException{ /** *思路:创建服务端 *1、创建SeverSocket客户端对象 *2、获取Socket流 *3、通过Socket,读取客户端发过来的需要转换的数据 *4、显示在控制台上 *5、将数据转换成大写返回给客户端 */ //1、创建SeverSocket对象 ServerSocketss=newServerSocket(10004); //2、获取Socket对象 Sockets=ss.accept(); //获取IP地址 Stringip=s.getInetAddress().getHostAddress(); System.out.println(ip+"......connected"); //3、获取Socket读取流,并装饰 BufferedReaderbufIn=newBufferedReader(newInputStreamReader(s.getInputStream())); //4、获取Socket的输出流,并装饰 PrintWriterout=newPrintWriter(s.getOutputStream(),true); Stringline=null; while((line=bufIn.readLine())!=null){ System.out.println(line); out.println(line.toUpperCase()); } s.close(); ss.close(); } }
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!