Java利用TCP协议实现客户端与服务器通信【附通信源码】

简介:

 

进行TCP协议网络程序的编写,关键在于ServerSocket套接字的熟练使用,TCP通信中所有的信息传输都是依托ServerSocket类的输入输出流进行的。

目录

TCP协议概念

ServerSocket类

服务器端程序

客户端程序


Hello!大家好哇!我是灰小猿!

上一篇博客和大家分享了在网络编程中要注意的基础知识,关于IP、TCP、UDP以及端口和套接字的一些概念,想了解的小伙伴可以看我的这篇文章“盘点那些进行网络编程必须要知道的基础知识”,那么今天大灰狼就来和大家分享一下如何使用TCP/IP进行网络程序的开发。

TCP协议概念

先来了解一下TCP协议的基本概念。

我们知道TCP是可靠而非安全的网络协议。它可以保证数据在从一端送至另一端的时候可以准确的送达,并且抵达的数据的排列顺序和送出时的顺序是相同的。因此在进行TCP协议通信的时候,我们首先应该保证客户端和服务器之间的连接通畅。

而TCP协议程序的编写,仍然是依靠套接字Socket类来实现的,并且利用TCP协议进行通信的两个程序之间是有主次之分的,即一个是服务器的程序,另一个是客户端的程序。因此两者的功能和编写上也略有不同。如下图是服务器与客户端之间进行通信的示意图:

image.gif编辑

以上就是在TCP协议中客户端与服务器建立连接的过程示意图。而在这其中起到关键作用的就是服务器端套接字ServerSocket和客户端套接字Socket。通过这两个套接字来建立服务器和客户端,从而利用其中的函数进行数据的通信。

在ServerSocket类中有很多需要注意的地方,接下来大灰狼和大家分享一下ServerSocket类的具体用法:

ServerSocket类

ServerSocket类存在于Java.net包中,表示服务器端的套接字,在使用时需要首先导入这个类,我们也知道ServerSocket类的主要功能就是通过指定的端口等待来自于网络中客户端的请求并且进行连接。

值得注意的是:服务器套接字一次只能与一个客户端套接字进行连接,因此如果存在多台客户端同时发送连接请求,则服务器套接字就会将请求的客户端存放到队列中去,然后从中取出一个套接字与服务器建立的套接字进行连接,但是服务器端能够容纳的客户端套接字也不是无限的,当请求连接的数量大于最大容纳量时,那么多出来的请求就会被拒接,一般来说队列的默认大小是50。

ServerSocket类的构造方法通常会抛出IOException异常,具体有以下几种形式:

    • ServerSocket():创建非绑定服务器套接字
    • ServerSocket(inr port):创建绑定到特定端口的服务器套接字
    • ServerSocket(int port, int backlog):利用指定的backlog创建服务器套接字,并将其绑定到指定的服务器端口上,
    • ServerSocket(int port, int backlog, InetAddress bindAddress):使用指定的端口,侦听backlog和要绑定到本地的IP地址创建服务器。这种情况适用于计算机上有多个网卡和多个IP地址的情况,用户可以明确的规定ServerSocket在哪块网卡或哪个IP地址上等待用户的连接请求。

    以下是ServerSocket类中一些常用的方法:

    ServerSocket类中常用的方法

    方法

    返回值 说明
    accept() Socket 等待客户机连接,若连接则创建一个客户端套接字
    isBound() boolean 判断ServerSocket的绑定状态
    getInetAddress() InetAddress 返回此服务器套接字的本地地址
    isClosed() boolean 返回服务器套接字的关闭状态
    close() void 关闭服务器套接字
    bind(SocketAddress endpoint) void 将ServerSocket绑定到特定地址(IP地址和端口号)
    getInetAddress() int 返回服务器套接字等待的端口号

    了解了ServerSocket类的基本方法之后,就是如何进行客户端和服务器进行连接的问题了。

    在服务器端我们可以调用ServerSocket类的accpet()方法与请求连接的客户机建立连接,这时会返回一个和客户端相连接的Socket对象,这个时候其实已经连接成功了,使用getInetAddress()方法就可以获取到进行请求的客户机的IP地址。

    对于如何进行客户端和服务器端数据的通信,就要用到数据的输入流和输出流了,服务器端的Socket对象使用getOutputStream()方法获取到的输出流,将指向客户端的Socket对象使用getInputStream()方法获取到的输入流。由此就实现在服务器向客户端发送数据的一个过程,同样的道理,客户端端的Socket对象使用getOutputStream()方法获取到的输出流,将指向服务器端的Socket对象使用getInputStream()方法获取到的输入流。从而实现由客户端向服务器发送数据的过程。

    注意:accpet()方法会阻塞线程的继续执行,如果在对应的接口没有收到客户端的呼叫,则程序会停留在此处,直到获取到客户端的呼叫才会继续向下执行,但是如果服务器没有收到来自客户端的呼叫请求,并且accpet()方法没有发生阻塞,那么通常情况下就是程序出了问题,一般来说可能是使用了一个已经被其他程序占用了的端口号,导致ServerSocket没有绑定成功!遇到这种情况可以尝试更换新的端口号。

    了解了TCP协议的通信过程,接下来就是进行TCP通信程序的书写啦!

    在网络通信中,如果只要求客户机向服务器发送信息,不要求服务器向客户端反馈信息的行为称为“单向通信”,要求客户机和服务器双方互相通信的过程称为“双向通信”,双向通信只不过是比单向通信多了一个服务器向客户端发送消息的过程,

    接下来分别是服务器端和客户端程序的编写:

    服务器端程序

    package server_1;
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    public class MyTcp {
      private ServerSocket server;  //设置服务器套接字
      private Socket client;    //设置客户端套接字
      //连接客户端函数
      void getServer()
      {
        try {
          server = new ServerSocket(1100);  //建立服务器 端口为1100
          System.out.println("服务器建立成功!正在等待连接......");
          client = server.accept(); //调用服务器函数对客户端进行连接     
          System.out.println("客户端连接成功!ip为:" + client.getInetAddress()); //返回客户端IP   
          getClientMessage();   //调用信息传输和接收函数
        } catch (IOException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
      }
      void getClientMessage()
      {
        try {
          while (true) {
            InputStream is = client.getInputStream(); //获取到客户端的输入流
            byte[] b = new byte[1024];  //定义字节数组
            int len = is.read(b); //由于信息的传输是以二进制的形式,所以要以二进制的形式进行数据的读取
            String data = new String(b, 0,len);
            System.out.println("客户端发来消息:" + data);
            //定义发送给客户端的输出流
            OutputStream put = client.getOutputStream();
            String putText = "我已经收到!欢迎你!";
            put.write(putText.getBytes());  //将输出流信息以二进制的形式进行写入
          }
        } catch (Exception e) {
          // TODO: handle exception
        }
        try {
          //判断客户端字节流不是空,则关闭客户端
          if (server != null) {
            server.close();
          }
        } catch (Exception e) {
          // TODO: handle exception
        }
      }
      public static void main(String[] args) {
        // TODO Auto-generated method stub
        MyTcp myTcp = new MyTcp();  //调用该类生成对象
        myTcp.getServer();  //调用方法
      }
    }

    image.gif

    客户端程序

    package client_1;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintWriter;
    import java.net.Socket;
    import java.net.UnknownHostException;
    public class MyClient {
      private Socket client;  //定义客户端套接字
      //建立客户端函数
      void getClient()
      {
        try {
          client = new Socket("127.0.0.1", 1100); //建立客户端,使用的IP为127.0.0.1,端口和服务器一样为1100
          System.out.println("客户端建立成功!");
          setClientMessage();   //调用客户端信息写入函数
        } catch (UnknownHostException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        } catch (IOException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
      }
      //定义客户端信息写入函数
      void setClientMessage()
      {
        try {   
          OutputStream pt = client.getOutputStream();   //建立客户端信息输出流
          String printText = "服务器你好!我是客户端!";  
          pt.write(printText.getBytes());   //以二进制的形式将信息进行输出
          InputStream input = client.getInputStream();  //建立客户端信息输入流
          byte [] b = new byte[1024];   //定义字节数组
          int len = input.read(b);  //读取接收的二进制信息流
          String data = new String(b, 0,len);
          System.out.println("收到服务器消息:" + data);
        } catch (IOException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
        try {
          //如果客户端信息流不为空,则说明客户端已经建立连接,关闭客户端
          if (client != null) {
            client.close();
          }
        } catch (Exception e) {
          // TODO: handle exception
        }
      }
      public static void main(String[] args) {
        // TODO Auto-generated method stub
        //生成客户端类对象
        MyClient myClient  = new MyClient();
        myClient.getClient();
      }
    }

    image.gif

    同时要注意:在客户端和服务器搭建成功之后,应该先打开服务器等待连接,再打开客户端进行连接,同样在进行关闭时,应该先关闭客户端,再关闭服务器。

    以上面程序为例:

    打开服务器等待客户端连接

    image.gif编辑

    打开客户端与服务器连接成功,并且实现双向通信:

    image.gif编辑

    注意:当一台机器上安装了多个网络应用程序时,很可能指定的端口已经被占用,甚至还可能遇到之前运行很好的程序突然卡住的情况,这种情况很可能是端口被别的程序占用了,这时可以运行netstat-help来活的帮助,可以使用命令netstat-an来查看该程序所使用的端口。

    觉得有用记得点赞关注哟!

    灰小猿期待与你一同进步^ω^

    image.gif编辑

    目录
    相关文章
    |
    7月前
    |
    人工智能 Java API
    MCP客户端调用看这一篇就够了(Java版)
    本文详细介绍了MCP(Model Context Protocol)客户端的开发方法,包括在没有MCP时的痛点、MCP的作用以及如何通过Spring-AI框架和原生SDK调用MCP服务。文章首先分析了MCP协议的必要性,接着分别讲解了Spring-AI框架和自研SDK的使用方式,涵盖配置LLM接口、工具注入、动态封装工具等步骤,并提供了代码示例。此外,还记录了开发过程中遇到的问题及解决办法,如版本冲突、服务连接超时等。最后,文章探讨了框架与原生SDK的选择,认为框架适合快速构建应用,而原生SDK更适合平台级开发,强调了两者结合使用的价值。
    10685 33
    MCP客户端调用看这一篇就够了(Java版)
    |
    7月前
    |
    存储 网络协议 Java
    Java获取客户端IP问题:返回127.0.0.1
    总结:要解决Java获取客户端IP返回127.0.0.1的问题,首先要找出原因,再采取合适的解决方案。请参考上述方案来改进代码,确保在各种网络环境下都能正确获取客户端IP地址。希望本文对您有所帮助。
    516 25
    |
    域名解析 网络协议 数据库
    TCP/IP服务器
    【10月更文挑战第20天】TCP/IP服务器
    318 65
    |
    JSON NoSQL Java
    redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)
    这篇文章介绍了在Java中使用Redis客户端的几种方法,包括Jedis、SpringDataRedis和SpringBoot整合Redis的操作。文章详细解释了Jedis的基本使用步骤,Jedis连接池的创建和使用,以及在SpringBoot项目中如何配置和使用RedisTemplate和StringRedisTemplate。此外,还探讨了RedisTemplate序列化的两种实践方案,包括默认的JDK序列化和自定义的JSON序列化,以及StringRedisTemplate的使用,它要求键和值都必须是String类型。
    redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)
    |
    存储 Java API
    Java实现导出多个excel表打包到zip文件中,供客户端另存为窗口下载
    Java实现导出多个excel表打包到zip文件中,供客户端另存为窗口下载
    935 4
    |
    分布式计算 Java Hadoop
    Hadoop-30 ZooKeeper集群 JavaAPI 客户端 POM Java操作ZK 监听节点 监听数据变化 创建节点 删除节点
    Hadoop-30 ZooKeeper集群 JavaAPI 客户端 POM Java操作ZK 监听节点 监听数据变化 创建节点 删除节点
    256 1
    |
    JavaScript 安全 Java
    谈谈UDP、HTTP、SSL、TLS协议在java中的实际应用
    下面我将详细介绍UDP、HTTP、SSL、TLS协议及其工作原理,并提供Java代码示例(由于Deno是一个基于Node.js的运行时,Java代码无法直接在Deno中运行,但可以通过理解Java示例来类比Deno中的实现)。
    271 1
    |
    消息中间件 Java Kafka
    【Azure 事件中心】在微软云中国区 (Mooncake) 上实验以Apache Kafka协议方式发送/接受Event Hubs消息 (Java版)
    【Azure 事件中心】在微软云中国区 (Mooncake) 上实验以Apache Kafka协议方式发送/接受Event Hubs消息 (Java版)
    365 1
    |
    Java
    Java使用FileInputStream&&FileOutputStream模拟客户端向服务器端上传文件(单线程)
    Java使用FileInputStream&&FileOutputStream模拟客户端向服务器端上传文件(单线程)
    215 1
    |
    2月前
    |
    弹性计算 运维 安全
    阿里云轻量应用服务器与云服务器ECS啥区别?新手帮助教程
    阿里云轻量应用服务器适合个人开发者搭建博客、测试环境等低流量场景,操作简单、成本低;ECS适用于企业级高负载业务,功能强大、灵活可扩展。二者在性能、网络、镜像及运维管理上差异显著,用户应根据实际需求选择。
    281 10