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编辑

    目录
    相关文章
    |
    8月前
    |
    存储 小程序 Java
    热门小程序源码合集:微信抖音小程序源码支持PHP/Java/uni-app完整项目实践指南
    小程序已成为企业获客与开发者创业的重要载体。本文详解PHP、Java、uni-app三大技术栈在电商、工具、服务类小程序中的源码应用,提供从开发到部署的全流程指南,并分享选型避坑与商业化落地策略,助力开发者高效构建稳定可扩展项目。
    |
    11月前
    |
    存储 安全 Java
    Java 集合面试题从数据结构到 HashMap 源码剖析详解及长尾考点梳理
    本文深入解析Java集合框架,涵盖基础概念、常见集合类型及HashMap的底层数据结构与源码实现。从Collection、Map到Iterator接口,逐一剖析其特性与应用场景。重点解读HashMap在JDK1.7与1.8中的数据结构演变,包括数组+链表+红黑树优化,以及put方法和扩容机制的实现细节。结合订单管理与用户权限管理等实际案例,展示集合框架的应用价值,助你全面掌握相关知识,轻松应对面试与开发需求。
    504 3
    |
    12月前
    |
    JavaScript Java 关系型数据库
    家政系统源码,java版本
    这是一款基于SpringBoot后端框架、MySQL数据库及Uniapp移动端开发的家政预约上门服务系统。
    400 6
    家政系统源码,java版本
    |
    供应链 JavaScript 前端开发
    Java基于SaaS模式多租户ERP系统源码
    ERP,全称 Enterprise Resource Planning 即企业资源计划。是一种集成化的管理软件系统,它通过信息技术手段,将企业的各个业务流程和资源管理进行整合,以提高企业的运营效率和管理水平,它是一种先进的企业管理理念和信息化管理系统。 适用于小微企业的 SaaS模式多租户ERP管理系统, 采用最新的技术栈开发, 让企业简单上云。专注于小微企业的应用需求,如企业基本的进销存、询价,报价, 采购、销售、MRP生产制造、品质管理、仓库库存管理、财务应收付款, OA办公单据、CRM等。
    859 23
    |
    前端开发 Java 关系型数据库
    基于Java+Springboot+Vue开发的鲜花商城管理系统源码+运行
    基于Java+Springboot+Vue开发的鲜花商城管理系统(前后端分离),这是一项为大学生课程设计作业而开发的项目。该系统旨在帮助大学生学习并掌握Java编程技能,同时锻炼他们的项目设计与开发能力。通过学习基于Java的鲜花商城管理系统项目,大学生可以在实践中学习和提升自己的能力,为以后的职业发展打下坚实基础。技术学习共同进步
    761 7
    |
    Java 关系型数据库 MySQL
    Java汽车租赁系统源码(含数据库脚本)
    Java汽车租赁系统源码(含数据库脚本)
    554 4
    |
    消息中间件 算法 安全
    JUC并发—1.Java集合包底层源码剖析
    本文主要对JDK中的集合包源码进行了剖析。
    |
    Java
    【源码】【Java并发】【ConcurrentHashMap】适合中学体质的ConcurrentHashMap
    本文深入解析了ConcurrentHashMap的实现原理,涵盖JDK 7与JDK 8的区别、静态代码块、构造方法、put/get/remove核心方法等。JDK 8通过Node数组+链表/红黑树结构优化并发性能,采用CAS和synchronized实现高效锁机制。文章还详细讲解了hash计算、表初始化、扩容协助及计数更新等关键环节,帮助读者全面掌握ConcurrentHashMap的工作机制。
    330 6
    【源码】【Java并发】【ConcurrentHashMap】适合中学体质的ConcurrentHashMap
    |
    人工智能 安全 Java
    智慧工地源码,Java语言开发,微服务架构,支持分布式和集群部署,多端覆盖
    智慧工地是“互联网+建筑工地”的创新模式,基于物联网、移动互联网、BIM、大数据、人工智能等技术,实现对施工现场人员、设备、材料、安全等环节的智能化管理。其解决方案涵盖数据大屏、移动APP和PC管理端,采用高性能Java微服务架构,支持分布式与集群部署,结合Redis、消息队列等技术确保系统稳定高效。通过大数据驱动决策、物联网实时监测预警及AI智能视频监控,消除数据孤岛,提升项目可控性与安全性。智慧工地提供专家级远程管理服务,助力施工质量和安全管理升级,同时依托可扩展平台、多端应用和丰富设备接口,满足多样化需求,推动建筑行业数字化转型。
    418 5
    |
    Java
    【源码】【Java并发】【LinkedBlockingQueue】适合中学体质的LinkedBlockingQueue入门
    前言 有了前文对简单实用的学习 【Java并发】【LinkedBlockingQueue】适合初学体质的LinkedBlockingQueue入门 聪明的你,一定会想知道更多。哈哈哈哈哈,下面主播就...
    274 6
    【源码】【Java并发】【LinkedBlockingQueue】适合中学体质的LinkedBlockingQueue入门