文档章节

基于NIO的消息路由的实现(二)通讯协议

皮鞋铮亮
 皮鞋铮亮
发布于 2015/08/18 09:36
字数 657
阅读 155
收藏 4

通讯协议可以根据自己的需要任意定义。我的定义如下:

一、术语定义:

名称

解释

备注

通道

指一个socket的连接通路

程序中,一般指SocketChannel

令牌

服务端用以区分连接通道的唯一标识

 

报文

指上行到达通讯主线程的通讯包

Packet

指令

指通讯主线程要发送给对端的下行通讯包

Order


二、规约(需仔细阅读)

所有报文和指令均有字符串组成,分为四个部分:

1、指令(报文)标记,大写英文字母,每一类指令(报文)都有自己唯一的标记;

2、指令(报文)流水号Rid;主动发起的指令,自动生成,最大1000000000,循环反复。被动响应的指令,为请求方的Rid回填。

3、指令(报文)Token,自动生成UUID;

4、指令体(报文);

除指令标记和指令流水号之外,其他两项内容,根据不同的指令(或报文),会有取舍;各部分之间以“|”作为分隔符。

例如:T|128|6e7805ec-8487-4ace-9c1e-cb715888b67f

5、所有报文传输,均采用UTF-8

6、报文中包含中文,请用Base64转码后发送;

服务端指令

1.       分配令牌

当客户端连接到服务端之后,服务端第一时间生成令牌,并下发此指令告知客户端。

类别

定义

备注

标记

T

 

流水号

自动生成,最大1000000000,循环反复

(例如:21

Token

UUID

6e7805ec-8487-4ace-9c1e-cb715888b6

示例:

T|128|6e7805ec-8487-4ace-9c1e-cb715888b67f

2.       错误

类别

定义

备注

标记

E

 

流水号

自动生成,最大1000000000,循环反复

(例如:21

Body

Json,内含errCodeerrMsg两个属性

{"errCode" : "1","errMsg" : "无效请求"}

示例:

E|128|{"errCode" : "1","errMsg" : "无效请求"}

3.       回应

类别

定义

备注

标记

R

 

流水号

是对应上行报文的Rid

(例如:21

示例:

R|102

三、服务端报文

1.       回应

类别

定义

备注

标记

R

 

流水号

是对应上行报文的Rid

(例如:21

Token

 

 

示例:

R|102|6e7805ec-8487-4ace-9c1e-cb715888b67f

2.       维持链路

类别

定义

备注

标记

K

 

流水号

是对应上行报文的Rid

(例如:21

Token

 

 

示例:

K|102|6e7805ec-8487-4ace-9c1e-cb715888b67f

3.       客户端登录

类别

定义

备注

标记

L

 

流水号

是对应上行报文的Rid

(例如:21

Token

用户的令牌

 

Body

用户的身份标记

此处为客户的业务身份标记,比如用户的系统账号,手机号等等

示例:

L|102|6e7805ec-8487-4ace-9c1e-cb715888b67f|13898482867

© 著作权归作者所有

共有 人打赏支持
皮鞋铮亮
粉丝 36
博文 12
码字总数 11603
作品 0
沈阳
私信 提问
基于NIO的消息路由的实现(一) 前言

一、前言: 已经很久没有碰编码了,大概有9年的时间,日新月异的框架和新东西让我眼花缭乱。之前一直在做web相关的应用。由于项目不大,分布式开发在我编码的那个年代里没有做过,后来走上管...

皮鞋铮亮
2015/08/17
0
16
Java远程通讯技术及原理分析

聊聊远程通信 Java远程通讯技术及原理分析 聊聊Socket、TCP/IP、HTTP、FTP及网络编程 RMI原理及实现 RPC原理及实现 轻量级分布式 RPC 框架 使用 RMI + ZooKeeper 实现远程调用框架 深入浅出S...

陶邦仁
2016/02/23
2.1K
2
基于netty实现的服务端Nio MVC业务开发--ketty

Ketty 基于 netty 实现的服务端 Nio MVC 业务开发平台,提供性能监控,日志分析,动态扩展的功能。 ketty-srv模块 基于netty实现支持自定义协议扩展的Nio MVC高性能业务框架 协议 Http Ketty...

郑大侠
2015/11/09
1K
0
郑大侠/jetty

##Ketty 基于netty实现的服务端Nio MVC业务开发平台,提供性能监控,日志分析,动态扩展的功能。 ###ketty-srv模块 基于netty实现支持自定义协议扩展的Nio MVC高性能业务框架 ####协议 Http...

郑大侠
2015/11/02
0
0
JMS 之 Active MQ 的消息传输

一、消息协商器(Message Broker) broke:消息的交换器,就是对消息进行管理的容器。ActiveMQ 可以创建多个 Broker,客户端与ActiveMQ交互,实际上都是与ActiveMQ中的Broker交互,Broker配置...

xsster
2017/07/28
0
0

没有更多内容

加载失败,请刷新页面

加载更多

EOS官方钱包keosd

EOS官方钱包的名称是keosd,它负责管理你的私钥,并且帮你进行交易的签名。 不过不幸的是,keosd钱包对普通用户并不友好,它是一个命令行程序,目前还没有像以太坊的mist那样的图形化界面,而...

汇智网教程
今天
23
0
ArrayList的实现原理以及实现线程安全

一、ArrayList概述 ArrayList是基于数组实现的,是一个动态的数字,可以自动扩容。 ArrayList不是线程安全的,效率比较高,只能用于单线程的环境中,在多线程环境中可以使用Collections.syn...

一看就喷亏的小猿
今天
28
0
Netty 备录 (一)

入职新公司不久,修修补补1个月的bug,来了点实战性的技术---基于netty即时通信 还好之前对socket有所使用及了解,入手netty应该不是很难吧,好吧,的确有点难,刚看这玩意的时候,可能都不知道哪里...

_大侠__
昨天
33
0
Django简单介绍和用户访问流程

Python下有许多款不同的 Web 框架。Django是重量级选手中最有代表性的一位。许多成功的网站和APP都基于Django。 Django是一个开放源代码的Web应用框架,由Python写成。 Django遵守BSD版权,初...

枫叶云
昨天
42
0
Spring Cloud Stream消费失败后的处理策略(四):重新入队(RabbitMQ)

应用场景 之前我们已经通过《Spring Cloud Stream消费失败后的处理策略(一):自动重试》一文介绍了Spring Cloud Stream默认的消息重试功能。本文将介绍RabbitMQ的binder提供的另外一种重试...

程序猿DD
昨天
22
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部