基于Java Socket的自定义协议，实现Android与服务器的长连接（一）-低调大师

基于Java Socket的自定义协议，实现Android与服务器的长连接（一）

2017-08-02 646

一、基础知识准备

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

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中各类型占字节数

byte 8位，1个字节
boolean 8位，1个字节
char 16位，2个字节
short 16位，2个字节
int 32位，4个字节
float 32位，4个字节
double 64位，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的状态是否处于连接中

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. 客户端

import java.net.Socket;
/**
* Created by meishan on 16/12/1.
*/
public class Client {
public static void main(String[] args) throws Exception {
boolean isConnected;
String host = "127.0.0.1";
int port = 1122;
Socket socket = null;
try {
socket = SocketFactory.getDefault().createSocket(host, port);
isConnected = true;
System.out.println("连接成功！");
} catch (ConnectException e) {
isConnected = false;
e.printStackTrace();
System.out.println("连接失败！");
}
if (!isConnected) {
return;
}
Thread.sleep(5000);
socket.close();
System.out.println("断开连接！");
}
}

2. 服务端

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/**
* Created by meishan on 16/12/1.
*/
public class Server {
private int port = 1122;
private ServerSocket serverSocket;
public Server() throws Exception {
serverSocket = new ServerSocket(port, 3);//显式设置连接请求队列的长度为3
System.out.println("服务器启动!");
}
public void service() {
while (true) {
Socket socket = null;
try {
socket = serverSocket.accept();
System.out.println("New connection accepted " + socket.getInetAddress() + ":" + socket.getPort());
} catch (IOException e) {
e.printStackTrace();
} finally {
if (socket != null) {
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
public static void main(String[] args) throws Exception {
Server server = new Server();
Thread.sleep(3000);
server.service();
}
}

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

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

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

1. 客户端

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
/**
* Created by meishan on 16/12/1.
*/
public class Client {
public static void main(String[] args) {
try {
Socket client = new Socket("127.0.0.1", 9091);
OutputStream out = client.getOutputStream();
DataOutputStream outs = new DataOutputStream(out);
while (true) {
Scanner scaner = new Scanner(System.in);
genProtocol(outs, scaner.next());
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 构造协议
*
* @param out
* @param msg
* @throws IOException
*/
private static void genProtocol(DataOutputStream out, String msg) throws IOException {
int type = 1; //消息类型
byte[] bytes = msg.getBytes(); //消息内容
int totalLen = 1 + 4 + bytes.length; //消息长度
out.writeByte(type); //写入消息类型
out.writeInt(totalLen); //写入消息长度
out.write(bytes); //写入消息内容
out.flush();
}
}

2. 服务端

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* Created by meishan on 16/12/1.
*/
public class Server {
public static void main(String[] args) {
try {
ServerSocket server = new ServerSocket(9091);
while (true) {
Socket client = server.accept();
System.out.println("客户端" + client.getRemoteSocketAddress() + "连接成功");
parseProtocol(client);
}
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 消息解析
*
* @param client
* @throws IOException
*/
private static void parseProtocol(Socket client) throws IOException {
InputStream is = client.getInputStream();
DataInputStream dis = new DataInputStream(is); //读取Java标准数据类型的输入流
//协议解析
while (true) {
byte type = dis.readByte(); //读取消息类型
int totalLen = dis.readInt(); //读取消息长度
byte[] data = new byte[totalLen - 4 - 1]; //定义存放消息内容的字节数组
dis.readFully(data); //读取消息内容
String msg = new String(data); //消息内容
System.out.println("接收消息类型" + type);
System.out.println("接收消息长度" + totalLen);
System.out.println("发来的内容是:" + msg);
}
}
}

四、总结

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

作者：枚杉

来源：51CTO

微信关注我们

原文链接：https://yq.aliyun.com/articles/182021

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

《Android的设计与实现：卷I》——第1章　1.5.2用Eclipse开发和调试源代码

1.5.2　用Eclipse开发和调试源代码 Eclipse是开发调试应用层以及应用框架层源代码最适合的工具，本节讲解如何搭建Eclipse开发和调试环境。开始前，请读者自行到Eclipse官方网站（http://www.eclipse.org/downloads/）下载Eclipse，推荐使用Eclipse Juno (v 4.2) - Eclipse for Mobile Developers版。 1．配置Eclipse 步骤1　安装ADT插件。启动Eclipse，在菜单栏中依次选择Help→Install New Software...→Add之后，弹出Add Repository提示框，在提示框的Name栏填写“Android-ADT-Plugin”（或者任意能标识ADT插件的名称），Location栏里填写“https://dl-ssl.google.com/android/eclipse/”，单击OK按钮，如图1-5所示。安装完成后重新启动Eclipse。步骤2　配置ADT和SDK。 ADT插件安装好后，需要在Eclipse中正确配置SDK才能使用。步骤如下：启动Ec...

2017-08-02

690

Hello，大家好，我是Clock。翻了一下简书，发现有一个多月没有更新博客，本来今天打算和妹纸去电影院看《你的名字》，然后再去到处浪的。结果因为妹纸公司临时有事，她不得不回公司一趟... 然后我也只能宅家里了，既然妹纸不在家，刚好最近一直在为项目做内存泄漏的优化工作，那就来写一点个人总结好了。什么是内存泄漏对于不同的语言平台来说，进行标记回收内存的算法是不一样的，像 Android(Java)则采用 GC-Root 的标记回收算法。下面这张图就展示了 Android 内存的回收管理策略(图来自Google 2011的IO大会) 图中的每个圆节点代表对象的内存资源，箭头代表可达路径。当圆节点与 GC Roots 存在可达路径时，表示当前资源正被引用，虚拟机是无法对其进行回收的(如图中的黄色节点)。反过来，如果圆节点与 GC Roots 不存在可达路径，则意味着这块对象的内存资源不再被程序引用，系统虚拟机可以在 GC 过程中将其回收掉。有了上面的内存回收的栗子，那么接下来就可以说说什么是内存泄漏了。从定义上讲，Android(Java)平台的内存泄漏是指没有用的对象资源任与GC-...

2017-08-02

640

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。