TCP网络编程
2021/5/22 12:58:15
本文主要是介绍TCP网络编程,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
目录
TCP网络编程练习
练习一:客户端发送信息给服务端,服务端将数据显示在控制台上。
客户端:
服务端
练习二:客户端发送文件给服务器,服务端将文件保存在本地。
客户端:
服务端:
练习三:在案例二的基础上,接收成功后,返回给客户端,接收成功!然后客户端才关闭连接!
客户端:
服务端:
TCP网络编程练习
练习一:客户端发送信息给服务端,服务端将数据显示在控制台上。
客户端:
package com.kou.lesson2; import java.io.IOException; import java.io.OutputStream; import java.net.InetAddress; import java.net.Socket; import java.net.UnknownHostException; //客户端 public class TcpClientDemo01 { public static void main(String[] args) { Socket socket = null; OutputStream os = null; try { //1. 连接服务器的地址 InetAddress serverIP = InetAddress.getByName("127.0.0.1"); int port = 8899; //2. 创建一个Socket socket = new Socket(serverIP,port); //3. 创建一个输出流,向外写东西 os = socket.getOutputStream(); os.write("你好".getBytes()); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { //4. 关闭资源 try { if (os!=null){ os.close(); } if (socket!=null){ socket.close(); } } catch (IOException e) { e.printStackTrace(); } } } }
服务端
package com.kou.lesson2; import javax.sound.midi.Soundbank; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.Base64; //服务端 public class TcpServerDemo01 { public static void main(String[] args) { ServerSocket serverSocket = null; Socket accept = null; InputStream is = null; ByteArrayOutputStream baos = null; try { //1. 开放服务器端口,创建ServerSocket serverSocket = new ServerSocket(8899); //2. 等待客户端的连接 accept = serverSocket.accept(); //3. 读入客户端的消息, is = accept.getInputStream(); /* 之前的IO流方案弊端:存在中文,可能存在乱码。 byte[] buffer = new byte[1024]; int len; while ((len=is.read(buffer))!=-1){ String str = new String(buffer,0,len); System.out.println(str); } **/ baos = new ByteArrayOutputStream(); byte[] buffer = new byte[1024]; int len; while ((len=is.read(buffer))!=-1){ baos.write(buffer,0,len); } System.out.println(baos.toString()); System.out.println( "数据来源地址:"+accept.getInetAddress().getHostName()); } catch (IOException e) { e.printStackTrace(); } finally { //4. 关闭资源 try { if (baos!=null){ baos.close(); } if (is!=null){ is.close(); } if (accept!=null){ accept.close(); } if (serverSocket!=null){ serverSocket.close(); } }catch (Exception e){ e.printStackTrace(); } } } }
练习二:客户端发送文件给服务器,服务端将文件保存在本地。
我们准备了一个图片(koudada.jpg)放在项目目录下:
客户端:
package com.kou.lesson3; import java.io.File; import java.io.FileInputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.Socket; //客户端 public class TcpClientDemo02 { public static void main(String[] args) throws Exception{ //1. 创建socket连接 Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9090); //2. 创建一个输出流 OutputStream os = socket.getOutputStream(); //3. 读取文件 FileInputStream fis = new FileInputStream(new File("koudada.jpg")); //4. 写出文件 byte[] buffer = new byte[1024]; int len; while ((len=fis.read(buffer))!=-1){ os.write(buffer,0,len); } //5. 资源关闭,应该使用 try-catch-finally fis.close(); os.close(); socket.close(); } } 点击并拖拽以移动
服务端:
package com.kou.lesson3; import java.io.*; import java.net.ServerSocket; import java.net.Socket; //服务端 public class TcpServerDemo02 { public static void main(String[] args) throws Exception { //1. 开启 ServerSocket ServerSocket serverSocket = new ServerSocket(9090); //2. 侦听 客户端 Socket Socket socket = serverSocket.accept(); //3. 获取输入流 InputStream is = socket.getInputStream(); //4. 读取接收的文件并保存 FileOutputStream fos = new FileOutputStream(newFile("kouxiaoxiao.jpg")); byte[] buffer = new byte[1024]; int len; while ((len=is.read(buffer))!=-1){ fos.write(buffer,0,len); } //5.关闭资源,应该使用 try-catch-finally fos.close(); is.close(); socket.close(); serverSocket.close(); } }
启动服务端,启动客户端,图片接收成功!
练习三:在案例二的基础上,接收成功后,返回给客户端,接收成功!然后客户端才关闭连接!
客户端:
package com.kou.lesson4; import java.io.*; import java.net.InetAddress; import java.net.Socket; //客户端 public class TcpClientDemo03 { public static void main(String[] args) throws Exception{ //1. 创建socket连接 Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9090); //2. 创建一个输出流 OutputStream os = socket.getOutputStream(); //3. 读取文件 FileInputStream fis = new FileInputStream(new File("koudada.jpg")); //4. 写出文件 byte[] buffer = new byte[1024]; int len; while ((len=fis.read(buffer))!=-1){ os.write(buffer,0,len); } //告诉服务器,我传输完了,关闭数据的输出,不然就会一直阻塞! socket.shutdownOutput(); //先别关,等待服务器响应,响应到控制台 InputStream inputStream = socket.getInputStream(); ByteArrayOutputStream baos = new ByteArrayOutputStream(); byte[] buffer2 = new byte[1024]; int len2; while ((len2=inputStream.read(buffer2))!=-1){ baos.write(buffer2,0,len2); } System.out.println(baos.toString()); //5. 资源关闭,应该使用 try-catch-finally baos.close(); inputStream.close(); fis.close(); os.close(); socket.close(); } }
服务端:
package com.kou.lesson4; import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; //服务端 public class TcpServerDemo03 { public static void main(String[] args) throws Exception { //1. 开启 ServerSocket ServerSocket serverSocket = new ServerSocket(9090); //2. 侦听 客户端 Socket Socket socket = serverSocket.accept(); //3. 获取输入流 InputStream is = socket.getInputStream(); //4. 读取接收的文件并保存 FileOutputStream fos = new FileOutputStream(newFile("kouxiaoxiao2.jpg")); byte[] buffer = new byte[1024]; int len; while ((len=is.read(buffer))!=-1){ fos.write(buffer,0,len); } //通知客户端接收成功 OutputStream outputStream = socket.getOutputStream(); outputStream.write("文件已经成功收到".getBytes()); //5.关闭资源,应该使用 try-catch-finally outputStream.close(); fos.close(); is.close(); socket.close(); serverSocket.close(); } }
这篇关于TCP网络编程的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-11-26Rocket消息中间件教程:新手入门详解
- 2024-11-26RocketMQ项目开发教程:新手入门指南
- 2024-11-26MQ源码教程:轻松入门Apache MQ源码解析
- 2024-11-26Rocket消息队列教程:新手入门必读
- 2024-11-26Rocket消息队列教程:新手入门指南
- 2024-11-26RocketMQ底层原理教程:新手入门指南
- 2024-11-26RocketMQ底层原理教程:入门级详解
- 2024-11-26如何获取 OpenAI API Key 用于ChatGPT AI大模型开发?
- 2024-11-26MATLAB 中 A(7)=[];什么意思?-icode9专业技术文章分享
- 2024-11-26UniApp 中如何实现使用输入法时保持页面列表不动的效果?-icode9专业技术文章分享