[javaSE] 网络编程(TCP服务端客户端互访阻塞)
2023-02-18 15:47:09 时间
客户端给服务端发送数据,服务端收到数据后,给客户端反馈数据
客户端:
获取Socket对象,new出来,构造参数:String的ip地址,int的端口号
调用Socket对象的getOutputStream()方法,获取到OutputStream对象
调用OutputStream对象的write()方法,输出流输出数据,参数:byte[]字节数组
调用Socket对象的getInputStream()方法,获取到InputStream对象
调用InputStream对象的read()方法,读取数据得到读取的长度,参数:byte[]字节数组
获取String对象,new出来,构造参数:byte[]字节数组,0开始,len长度
调用Socket对象的close()方法,关闭socket
客户端的输入流读取read()方法,是阻塞式方法,会在这里等待服务端返回数据
服务端:
获取ServerSocket对象,new出来,构造参数:int的端口号
调用ServerSocket对象的accept()方法,得到Socket对象
调用Socket对象的getInputStream()方法,得到输入流对象,解析输入流
调用Socket对象的getOutputStream()方法,得到输出流对象,输出数据
调用Socket对象的close()方法,关闭socket
调用ServerSocket对象的close()方法,关闭ServerSocket
服务端的accept()方法,是阻塞式方法,会在这里等待客户端的连接
Server.java
import java.io.InputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; /** * 服务端 * * @author taoshihan * */ public class Server { public static void main(String[] args) throws Exception { ServerSocket serverSocket = new ServerSocket(10004); // while (true) { Socket socket = serverSocket.accept(); InputStream inputStream = socket.getInputStream(); byte[] buf = new byte[1024]; int len = inputStream.read(buf); InetAddress ip = socket.getInetAddress(); System.out.println("来自" + ip.getHostAddress() + "说:" + new String(buf, 0, len)); Thread.sleep(10000);//睡眠10秒钟,客户端会一直等待 OutputStream out=socket.getOutputStream(); out.write("我是服务端,已经收到信息".getBytes()); socket.close(); serverSocket.close(); //} } }
import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.Socket; /** * 客户端 * @author taoshihan * */ public class Client { public static void main(String[] args) throws Exception, IOException { Socket socket=new Socket(InetAddress.getLocalHost(), 10004); OutputStream outputStream=socket.getOutputStream(); outputStream.write("我是客户端,服务端你好".getBytes()); InputStream in=socket.getInputStream(); byte[] b=new byte[1024]; int len=in.read(b);//这里会阻塞,等待服务端的返回 System.out.println(new String(b,0,len)); socket.close(); } }
Client.java
相关文章
- 漫谈图像超分辨率技术
- Centos7 运行Springboot打包后的jar文件的相关操作
- OpenFeign设置超时时间
- nacos集群配置
- 各个微服务认证授权的处理方法
- EasyExcel中无法使用Spring事务的解决办法
- 自定义注解实现防重复提交(纯后端解决)
- RabbitMQ + Haproxy 实现高可用镜像集群
- 开源 | 用深度学习让你的照片变得美丽
- 机器视觉入门知识总结
- Screaming Frog SEO Spider for Mac(网络爬虫开发工具) 18.1注册激活版
- 深度好文:理解可变形卷积和光流对齐
- Nacos2.1.0 - 外网服务器上的集群部署
- 听说,3D ToF传感器将成研发主流!
- markdown语法简介
- 让typecho支持table of contents
- 正则表达式教程
- 记一次bypy的使用
- bad interpreter 没有那个文件或目录
- vim入门