基于Java Socket的自定义协议,实现Android与服务器的长连接(一)

简介:

一、基础知识准备

在正式给大家介绍自定义协议之前,我们先对网络传输和协议解析的相关知识点做一个基本的介绍,尽管这些知识点我们在学校里学过,但难免会有所遗忘,这里先做一个简单的介绍,以便对后文的内容理解更加顺畅。

1. 网络七层协议

OSI的7层从上到下分别是:7 应用层、 6 表示层、 5 会话层、 4 传输层、 3 网络层、 2 数据链路层、 1 物理层;其中高层(即7、6、5、4层)定义了应用程序的功能,下面3层(即3、2、1层)主要面向通过网络的端到端的数据流。应用层常见的协议有:HTTP、FTP、SMTP等;常见的传输层有:TCP、UDP。本文主要是基于TCP自定义协议实现客户端与服务端的长连接。

2. Socket

Socket本质是编程接口(API),对TCP/IP的封装,TCP/IP也要提供可供程序员做网络开发所用的接口,这就是Socket编程接口,通常也称作"套接字"。套接字之间的连接过程可以分为三个步骤:客户端请求,服务端回复收到,客户端收到服务端的回复,即三次握手。连接成功时,应用程序两端都会产生一个Socket实例,操作这个实例完成所需的会话。对于一个网络连接来说,套接字是平等的,并没有差别,不因为在服务器端或在客户端而产生不同级别。

3. 位(bit)、字节(byte)

“位(bit)”是电子计算机中最小的数据单位。每一位的状态只能是0或1;“字节(Byte)”由8个二进制位构成(即1byte=8bit),它是存储空间的基本计量单位,它能表示到数值范围为0到255(即2的8次方减1);

4. 算术移位运算(符号位不变,低位补0)

  • 左移运算:1<<2,1的二进制位是1,向左移两位是100,转为十进制数即为4,所以1<<2的运算结果是4;
  • 右移运算:7>>2,7的二进制位是111,向右移两位是1,所以7>>2的运算结果是1 。

5. Java中各类型占字节数


  
  
  1. byte      8位,1个字节 
  2. boolean   8位,1个字节 
  3. char      16位,2个字节 
  4. short     16位,2个字节 
  5. int       32位,4个字节 
  6. float     32位,4个字节 
  7. double    64位,8个字节 
  8. long      64位,8个字节  

6. Java中socket相关函数

  • Socket构造函数
    • Socket(InetAddress address, int port)throws UnknownHostException, IOException
    • Socket(InetAddress address, int port, InetAddress localAddress, int localPort)throws IOException
    • Socket(String host, int port)throws UnknownHostException, IOException
    • Socket(String host, int port, InetAddress localAddress, int localPort)throws IOException
    • 还可以通过以下方式生成socket:

SocketFactory.getDefault().createSocket(String address, String port) throws ConnectException

  • Socket方法
    • getInetAddress(); // 远程服务端的IP地址
    • getPort(); // 远程服务端的端口
    • getLocalAddress(); // 本地客户端的IP地址
    • getLocalPort(); // 本地客户端的端口
    • getInputStream(); // 获得输入流
    • getOutStream(); // 获得输出流
  • Socket状态
    • isClosed(); // 连接是否已关闭,若关闭,返回true;否则返回false
    • isConnect(); // 如果曾经连接过,返回true;否则返回false
    • isBound(); // 如果Socket已经与本地一个端口绑定,返回true;否则返回false
    • 判断Socket的状态是否处于连接中 

  
  
  1. boolean isConnected = socket.isConnected() && !socket.isClosed(); // 判断当前是否处于连接 
  • ServerSocket构造函数
    • ServerSocket()throws IOException
    • ServerSocket(int port)throws IOException
    • ServerSocket(int port, int backlog)throws IOException
    • ServerSocket(int port, int backlog, InetAddress bindAddr)throws IOException
  • 服务端接收客户端的连接请求:
    • Socket socket = serverSocket.accept();

7. Java中常见流操作类

  • 输入流
    • InputStream
      • 抽象类,描述流的输入
    • ByteArrayInputStream
      • 从字节数组读取的输入流
    • BufferedInputStream
      • 缓冲输入流
    • FileInputStream
      • 从文件读入的输入流
    • ObjectInputStream
      • 对象输入流(所读写的对象必须实现Serializable接口)
    • DataInputStream
      • 包含了读取Java标准数据类型的输入流
  • 输出流
    • OutputStream
      • 抽象类,描述流的输入
    • ByteArrayOutputStream
      • 写入字节数组的输出流
    • BufferedOutputStream
      • 缓冲输出流
    • FileOutputStream
      • 写入文件的输出流
    • ObjectOutputStream
      • 对象输出流(所读写的对象必须实现Serializable接口)
    • DataOutputStream
      • 包含了写Java标准数据类型的输出流

二、一个简单的socket连接例子

注:先运行服务端代码的main函数,再运行客户端代码的main函数,即可看到打印连接成功

1. 客户端


  
  
  1. import java.net.Socket; 
  2.  
  3. /** 
  4.  * Created by meishan on 16/12/1. 
  5.  */ 
  6. public class Client { 
  7.     public static void main(String[] args) throws Exception { 
  8.         boolean isConnected; 
  9.         String host = "127.0.0.1"
  10.         int port = 1122; 
  11.         Socket socket = null
  12.         try { 
  13.             socket = SocketFactory.getDefault().createSocket(host, port); 
  14.             isConnected = true
  15.             System.out.println("连接成功!"); 
  16.         } catch (ConnectException e) { 
  17.             isConnected = false
  18.             e.printStackTrace(); 
  19.             System.out.println("连接失败!"); 
  20.         } 
  21.  
  22.         if (!isConnected) { 
  23.             return
  24.         } 
  25.  
  26.         Thread.sleep(5000); 
  27.  
  28.         socket.close(); 
  29.         System.out.println("断开连接!"); 
  30.     } 
  31.  

2. 服务端


  
  
  1. import java.io.IOException; 
  2. import java.net.ServerSocket; 
  3. import java.net.Socket; 
  4.  
  5. /** 
  6.  * Created by meishan on 16/12/1. 
  7.  */ 
  8. public class Server { 
  9.  
  10.     private int port = 1122; 
  11.     private ServerSocket serverSocket; 
  12.  
  13.     public Server() throws Exception { 
  14.         serverSocket = new ServerSocket(port, 3);//显式设置连接请求队列的长度为3 
  15.         System.out.println("服务器启动!"); 
  16.     } 
  17.  
  18.     public void service() { 
  19.         while (true) { 
  20.             Socket socket = null
  21.             try { 
  22.                 socket = serverSocket.accept(); 
  23.                 System.out.println("New connection accepted " + socket.getInetAddress() + ":" + socket.getPort()); 
  24.             } catch (IOException e) { 
  25.                 e.printStackTrace(); 
  26.             } finally { 
  27.                 if (socket != null) { 
  28.                     try { 
  29.                         socket.close(); 
  30.                     } catch (IOException e) { 
  31.                         e.printStackTrace(); 
  32.                     } 
  33.                 } 
  34.             } 
  35.         } 
  36.     } 
  37.  
  38.     public static void main(String[] args) throws Exception { 
  39.         Server server = new Server(); 
  40.         Thread.sleep(3000); 
  41.         server.service(); 
  42.     } 
  43.  

三、一个简单的自定义协议例子

例子中,数据包的定义:消息对象=包类型+包长度+消息内容

  • 包类型 byte 型
  • 包长度 int 型
  • 消息内容 byte[] 型

1. 客户端


  
  
  1. import java.io.DataOutputStream; 
  2. import java.io.IOException; 
  3. import java.io.OutputStream; 
  4. import java.net.Socket; 
  5. import java.net.UnknownHostException; 
  6. import java.util.Scanner; 
  7.  
  8. /** 
  9.  * Created by meishan on 16/12/1. 
  10.  */ 
  11. public class Client { 
  12.  
  13.     public static void main(String[] args) { 
  14.         try { 
  15.             Socket client = new Socket("127.0.0.1", 9091); 
  16.             OutputStream out = client.getOutputStream(); 
  17.             DataOutputStream outs = new DataOutputStream(out); 
  18.             while (true) { 
  19.                 Scanner scaner = new Scanner(System.in); 
  20.                 genProtocol(outs, scaner.next()); 
  21.             } 
  22.         } catch (UnknownHostException e) { 
  23.             e.printStackTrace(); 
  24.         } catch (IOException e) { 
  25.             e.printStackTrace(); 
  26.         } 
  27.     } 
  28.  
  29.     /** 
  30.      * 构造协议 
  31.      * 
  32.      * @param out 
  33.      * @param msg 
  34.      * @throws IOException 
  35.      */ 
  36.     private static void genProtocol(DataOutputStream out, String msg) throws IOException { 
  37.         int type = 1;                          //消息类型 
  38.         byte[] bytes = msg.getBytes();         //消息内容 
  39.         int totalLen = 1 + 4 + bytes.length;   //消息长度 
  40.  
  41.         out.writeByte(type);                   //写入消息类型 
  42.         out.writeInt(totalLen);                //写入消息长度 
  43.         out.write(bytes);                      //写入消息内容 
  44.  
  45.         out.flush(); 
  46.     } 
  47.  

2. 服务端


  
  
  1. import java.io.DataInputStream; 
  2. import java.io.IOException; 
  3. import java.io.InputStream; 
  4. import java.net.ServerSocket; 
  5. import java.net.Socket; 
  6.  
  7. /** 
  8.  * Created by meishan on 16/12/1. 
  9.  */ 
  10. public class Server { 
  11.  
  12.     public static void main(String[] args) { 
  13.         try { 
  14.             ServerSocket server = new ServerSocket(9091); 
  15.             while (true) { 
  16.                 Socket client = server.accept(); 
  17.                 System.out.println("客户端" + client.getRemoteSocketAddress() + "连接成功"); 
  18.                 parseProtocol(client); 
  19.             } 
  20.         } catch (IOException e) { 
  21.             e.printStackTrace(); 
  22.         } 
  23.     } 
  24.  
  25.     /** 
  26.      * 消息解析 
  27.      * 
  28.      * @param client 
  29.      * @throws IOException 
  30.      */ 
  31.     private static void parseProtocol(Socket client) throws IOException { 
  32.         InputStream is = client.getInputStream(); 
  33.         DataInputStream dis = new DataInputStream(is); //读取Java标准数据类型的输入流 
  34.  
  35.         //协议解析 
  36.         while (true) { 
  37.             byte type = dis.readByte();               //读取消息类型 
  38.             int totalLen = dis.readInt();             //读取消息长度 
  39.             byte[] data = new byte[totalLen - 4 - 1]; //定义存放消息内容的字节数组 
  40.             dis.readFully(data);                      //读取消息内容 
  41.             String msg = new String(data);            //消息内容 
  42.  
  43.             System.out.println("接收消息类型" + type); 
  44.             System.out.println("接收消息长度" + totalLen); 
  45.             System.out.println("发来的内容是:" + msg); 
  46.         } 
  47.     } 
  48.  

四、总结

本文简单介绍了socket通信和自定义协议的相关知识点,为后续的深入做一些准备工作,下一篇文章《基于Java Socket的自定义协议,实现Android与服务器的长连接(二)》将通过一个实例来详细讲解自定义协议实现长连接通信。




作者:枚杉
来源:51CTO
目录
相关文章
|
3月前
|
Java
java小工具util系列5:java文件相关操作工具,包括读取服务器路径下文件,删除文件及子文件,删除文件夹等方法
java小工具util系列5:java文件相关操作工具,包括读取服务器路径下文件,删除文件及子文件,删除文件夹等方法
110 9
|
3月前
|
缓存 前端开发 Android开发
安卓开发中的自定义视图:从零到英雄
【10月更文挑战第42天】 在安卓的世界里,自定义视图是一块画布,让开发者能够绘制出独一无二的界面体验。本文将带你走进自定义视图的大门,通过深入浅出的方式,让你从零基础到能够独立设计并实现复杂的自定义组件。我们将探索自定义视图的核心概念、实现步骤,以及如何优化你的视图以提高性能和兼容性。准备好了吗?让我们开始这段创造性的旅程吧!
55 1
|
4月前
|
Android开发 开发者
安卓应用开发中的自定义视图
【9月更文挑战第37天】在安卓开发的海洋中,自定义视图犹如一座座小岛,等待着勇敢的探索者去发现其独特之处。本文将带领你踏上这段旅程,从浅滩走向深海,逐步揭开自定义视图的神秘面纱。
52 3
|
4月前
|
数据可视化 Android开发 开发者
安卓应用开发中的自定义View组件
【10月更文挑战第5天】在安卓应用开发中,自定义View组件是提升用户交互体验的利器。本篇将深入探讨如何从零开始创建自定义View,包括设计理念、实现步骤以及性能优化技巧,帮助开发者打造流畅且富有创意的用户界面。
150 0
|
2月前
|
存储 人工智能 自然语言处理
ChatMCP:基于 MCP 协议开发的 AI 聊天客户端,支持多语言和自动化安装 MCP 服务器
ChatMCP 是一款基于模型上下文协议(MCP)的 AI 聊天客户端,支持多语言和自动化安装。它能够与多种大型语言模型(LLM)如 OpenAI、Claude 和 OLLama 等进行交互,具备自动化安装 MCP 服务器、SSE 传输支持、自动选择服务器、聊天记录管理等功能。
268 15
ChatMCP:基于 MCP 协议开发的 AI 聊天客户端,支持多语言和自动化安装 MCP 服务器
|
4月前
|
Python
Socket学习笔记(二):python通过socket实现客户端到服务器端的图片传输
使用Python的socket库实现客户端到服务器端的图片传输,包括客户端和服务器端的代码实现,以及传输结果的展示。
215 3
Socket学习笔记(二):python通过socket实现客户端到服务器端的图片传输
|
3月前
|
搜索推荐 前端开发 Android开发
安卓应用开发中的自定义视图实现
【10月更文挑战第30天】在安卓开发的海洋中,自定义视图是那抹不可或缺的亮色,它为应用界面的个性化和交互体验的提升提供了无限可能。本文将深入探讨如何在安卓平台创建自定义视图,并展示如何通过代码实现这一过程。我们将从基础出发,逐步引导你理解自定义视图的核心概念,然后通过一个实际的代码示例,详细讲解如何将理论应用于实践,最终实现一个美观且具有良好用户体验的自定义控件。无论你是想提高自己的开发技能,还是仅仅出于对安卓开发的兴趣,这篇文章都将为你提供价值。
|
3月前
|
Android开发 开发者 UED
安卓开发中自定义View的实现与性能优化
【10月更文挑战第28天】在安卓开发领域,自定义View是提升应用界面独特性和用户体验的重要手段。本文将深入探讨如何高效地创建和管理自定义View,以及如何通过代码和性能调优来确保流畅的交互体验。我们将一起学习自定义View的生命周期、绘图基础和事件处理,进而探索内存和布局优化技巧,最终实现既美观又高效的安卓界面。
64 5
|
4月前
|
JSON 数据格式 Python
Socket学习笔记(一):python通过socket实现客户端到服务器端的文件传输
本文介绍了如何使用Python的socket模块实现客户端到服务器端的文件传输,包括客户端发送文件信息和内容,服务器端接收并保存文件的完整过程。
243 1
Socket学习笔记(一):python通过socket实现客户端到服务器端的文件传输
|
4月前
|
Java Linux
java读取linux服务器下某文档的内容
java读取linux服务器下某文档的内容
55 3
java读取linux服务器下某文档的内容

热门文章

最新文章

  • 1
    如何修复 Android 和 Windows 不支持视频编解码器的问题?
  • 2
    【08】flutter完成屏幕适配-重建Android,增加GetX路由,屏幕适配,基础导航栏-多版本SDK以及gradle造成的关于fvm的使用(flutter version manage)-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
  • 3
    当flutter react native 等混开框架-并且用vscode-idea等编译器无法打包apk,打包安卓不成功怎么办-直接用android studio如何打包安卓apk -重要-优雅草卓伊凡
  • 4
    【04】flutter补打包流程的签名过程-APP安卓调试配置-结构化项目目录-完善注册相关页面-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程
  • 5
    APP-国内主流安卓商店-应用市场-鸿蒙商店上架之必备前提·全国公安安全信息评估报告如何申请-需要安全评估报告的资料是哪些-优雅草卓伊凡全程操作
  • 6
    【02】写一个注册页面以及配置打包选项打包安卓apk测试—开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草央千澈
  • 7
    Android经典面试题之Kotlin中Lambda表达式和匿名函数的区别
  • 8
    【09】flutter首页进行了完善-采用android studio 进行真机调试开发-增加了直播间列表和短视频人物列表-增加了用户中心-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
  • 9
    阿里云轻量应用服务器出新品通用型实例了,全球26个地域可选
  • 10
    在阿里云ECS上一键部署DeepSeek-R1