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

    目录
    相关文章
    |
    11天前
    |
    Java Android开发
    java利用xml-rpc协议操作wordpress博客
    java利用xml-rpc协议操作wordpress博客
    16 1
    |
    5天前
    |
    网络协议 数据格式 Python
    Python进阶---HTTP协议和Web服务器
    Python进阶---HTTP协议和Web服务器
    18 4
    |
    5天前
    |
    网络协议 Python
    在python中利用TCP协议编写简单网络通信程序,要求服务器端和客户端进行信息互传。 - 蓝易云
    在这个示例中,服务器端创建一个socket并监听本地的12345端口。当客户端连接后,服务器发送一条欢迎消息,然后关闭连接。客户端创建一个socket,连接到服务器,接收消息,然后关闭连接。
    59 0
    |
    11天前
    |
    网络协议 Java API
    深度剖析:Java网络编程中的TCP/IP与HTTP协议实践
    【4月更文挑战第17天】Java网络编程重在TCP/IP和HTTP协议的应用。TCP提供可靠数据传输,通过Socket和ServerSocket实现;HTTP用于Web服务,常借助HttpURLConnection或Apache HttpClient。两者结合,构成网络服务基础。Java有多种高级API和框架(如Netty、Spring Boot)简化开发,助力高效、高并发的网络通信。
    |
    11天前
    |
    网络协议 Python
    python中TCP回声服务器与客户端示例
    【4月更文挑战第7天】本示例展示了TCP回声服务器和客户端的工作流程。服务器监听特定端口,接收客户端连接请求,接收数据并回显。客户端连接服务器,发送数据并接收回显。代码示例用Python实现,包括服务器的`socket.bind()`, `socket.listen()`, `socket.accept()`和客户端的`socket.connect()`, `socket.sendall()`, `socket.recv()`。运行示例时,先启动服务器再启动客户端,可观察TCP连接和数据传输过程。了解这些基础对于构建网络应用至关重要。
    |
    11天前
    |
    网络协议 安全 Java
    理解HTTP协议:Java Web开发的基础
    【4月更文挑战第3天】本文介绍了HTTP协议的基础知识,包括其无状态、应用层协议的特性,基于请求/响应的工作模式,以及TCP连接、HTTP请求和响应的流程。HTTP方法如GET、POST、PUT等用于不同操作,状态码则表示请求结果。在Java Web开发中,理解HTTP有助于设计RESTful API、管理状态、确保安全性、优化性能和处理错误。HTTP协议的深入理解对构建高效、健壮和安全的Web应用至关重要。
    |
    11天前
    |
    网络协议 网络架构
    tcp端口转发服务器--forwardSvr
    tcp端口转发服务器--forwardSvr
    20 1
    |
    11天前
    |
    JSON 网络协议 开发工具
    基于Qt实现的TCP端口数据转发服务器
    基于Qt实现的TCP端口数据转发服务器
    23 0
    基于Qt实现的TCP端口数据转发服务器
    时间轮-Java实现篇
    在前面的文章《[时间轮-理论篇](https://developer.aliyun.com/article/910513)》讲了时间轮的一些理论知识,然后根据理论知识。我们自己来实现一个简单的时间轮。
    |
    1天前
    |
    Java 开发者
    Java中的多线程编程:理解、实现与性能优化
    【5月更文挑战第25天】 在Java中,多线程编程是实现并发执行任务的关键手段。本文将深入探讨Java多线程的核心概念,包括线程的创建、生命周期、同步机制以及高级特性。我们将通过实例演示如何有效地创建和管理线程,同时着重分析多线程环境下的性能调优策略和常见问题解决方法。文章旨在为读者提供一个全面的视角,帮助其掌握Java多线程编程的技巧,并在实际开发中避免潜在的并发问题,提升程序的性能和稳定性。