当前位置: 首页 > news >正文

TCP网络通信

 

 TCP通信的 实现发1收1

package TCP1;//完成TCP通信的 实现发1收1import java.io.DataOutputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;public class Client {public static void main(String[] args)throws Exception {//1:创建Socket对象并同时请求服务端程序的链接Socket socket= new Socket("127.0.0.1",8888);//2:从Socket通信管道中得到一个字节输出流 用来数据发给到服务器OutputStream os= socket.getOutputStream();//3:把低级的输出流封装成数据输出流DataOutputStream dos=  new DataOutputStream(os);//开始写数据出去了dos.writeUTF("在一起好吗?");System.out.println("发送完成");dos.close();    //释放资源IO流socket.close();  //释放网络资源TCP通信}}

 

package TCP1;// 完成TCP通信服务端 实现发1收1import java.io.DataInputStream;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;public class Server {public static void main(String[] args) throws Exception {System.out.println("===============启动服务端================");//1:创建serverSocket的对象 同时为服务端注册端口ServerSocket serverSocket = new ServerSocket(8888);//2:使用serverSocket 对象 调用accept 方法 等待客户端连接请求Socket socket= serverSocket.accept();//3:从socket管道中得到一个字节输入流InputStream inputStream = socket.getInputStream();//4: 把原始的字节输入流封装成输入流DataInputStream dis=  new DataInputStream(inputStream);//5:使用数据输入流 读取客户端发箍来的数据String rs= dis.readUTF();System.out.println(rs);// 6:谁发的数据获取IPSystem.out.println(socket.getRemoteSocketAddress());System.out.println(socket.getPort());dis.close();    //释放资源IO流socket.close();  //释放网络资源TCP通信}}

完成TCP通信的 多发多收

package TCP2;//完成TCP通信的 多发多收import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;public class Client {public static void main(String[] args)throws Exception {//1:创建Socket对象并同时请求服务端程序的链接Socket socket= new Socket("127.0.0.1",8888);//2:从Socket通信管道中得到一个字节输出流 用来数据发给到服务器OutputStream os= socket.getOutputStream();//3:把低级的输出流封装成数据输出流DataOutputStream dos=  new DataOutputStream(os);Scanner sr=new Scanner(System.in);while (true) {//开始写数据出去了System.out.print("请说: ");String msg= sr.nextLine();dos.writeUTF(msg);dos.flush();//用户输入exit 退出if ("exit".equals(msg)){System.out.println("欢迎下次光临 退出成功");dos.close();socket.close();break;}}}}

 

package TCP2;// 完成TCP通信服务端  多发多收import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;public class Server {public static void main(String[] args) throws Exception {System.out.println("===============服务端启动成功================");//1:创建serverSocket的对象 同时为服务端注册端口ServerSocket serverSocket = new ServerSocket(8888);//2:使用serverSocket 对象 调用accept 方法 等待客户端连接请求Socket socket= serverSocket.accept();//3:从socket管道中得到一个字节输入流InputStream inputStream = socket.getInputStream();//4: 把原始的字节输入流封装成输入流DataInputStream dis=  new DataInputStream(inputStream);while (true) {//5:使用数据输入流 读取客户端发箍来的数据try {String rs= dis.readUTF();System.out.println(rs);} catch (Exception e) {System.out.println(socket.getRemoteSocketAddress()+"离线了!");socket.close();dis.close();break;}// 6:谁发的数据获取IP// System.out.println(socket.getRemoteSocketAddress());//System.out.println(socket.getPort());}}}

http://www.lryc.cn/news/206014.html

相关文章:

  • echarts中,X轴名称过长隐藏,鼠标hove显示全称
  • laravel框架介绍(二) 打开站点:autoload.php报错
  • reactNative导入excel文件
  • mysql 命令行安装
  • JAVA基础知识Fundamental
  • 民宿如何经营与管理?【民宿小程序】
  • 用 Rust 和 cURL 库制作一个有趣的爬虫
  • 华为OD 走方格的方案数(100分)【java】A卷+B卷
  • postgresql|数据库|序列Sequence的创建和管理
  • (完全解决)如何输入一个图的邻接矩阵(每两个点的亲密度矩阵affinity),然后使用sklearn进行谱聚类
  • Unity中Shader的ShaderLOD
  • 图像压缩(4)《数字图像处理》第八章 8.3节 数字图像水印
  • C++之lambda匿名函数总结(二百四十五)
  • STM32F103单片机内部RTC实时时钟驱动程序
  • ChinaSoft 论坛巡礼 | 开源软件生态健康度量论坛
  • Leetcode.2698 求一个整数的惩罚数
  • 大数据Flink(一百零二):SQL 聚合函数(Aggregate Function)
  • 因mapjoin加载内存溢出而导致return code 3
  • pip 指定源
  • 嵌入式中的MCU、ARM、DSP、FPGA
  • 二、PHP基础学习[变量]
  • k8s kubeadm配置
  • B-3:Web安全之综合渗透测试
  • 设计模式—设计模式总览
  • C++ 流程控制(分支、循环、跳转)
  • 【网络协议】聊聊TCP的三挥四握
  • Docker镜像仓库
  • 跨界技术:SOCKS5代理在电商、爬虫与游戏领域的应用
  • LeetCode--快速排序
  • 2023年CSP-S赛后总结(2023CSP-S题解)