如何做一个国产数据库一
如何做一个国产数据库二
如何做一个国产数据库三
如何做一个国产数据库四
如何做一个国产数据库五
如何做一个国产数据库六

server端协议定义

再次强调一下我们的protocol 应用层的协议，其中协议第一个字节的前两位如下所示
//1字节 2位
//00 发布数据
//01 订阅数据
//10 心跳数据
//11 返回数据
所以服务端在接收到头部字节结束后，可以知道客户端时订阅客户端还是发布了

 int on_headers_complete(void* param) {//client_t* pclient = (client_t*)param;printf("the header len is %d\n", pclient->recvlen);//printf("the id is %04x\n", getid(pclient));client_t* cl = (client_t*)param;//得到头部字节char head = cl->head[0];char type = head >> 6;switch (type){case 0x00://00 发布数据//放入发布列表cout << "publish" << endl;break;case 0x01://01 订阅数据//放入订阅列表cout << "subscribe" << endl;break;case 0x02://10 心跳数据cout << "heartbeat" << endl;break;}return 0;}

接下去，就可以把订阅和发布客户端分别放到不同的队列里面去了，暂时不讲这些，先讲如何使用java做我们的订阅客户端，java最常用的就是netty，下面我们使用netty来做一个客户端。以下是tcpclient.java

import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.channel.ChannelPipeline;
public class TcpClient {// 要请求的服务器的ip地址private String ip;// 服务器的端口private int port;public TcpClient(String ip, int port){this.ip = ip;this.port = port;}// 请求端主题private void action() throws InterruptedException {EventLoopGroup bossGroup = new NioEventLoopGroup();Bootstrap bs = new Bootstrap();bs.group(bossGroup).channel(NioSocketChannel.class).option(ChannelOption.SO_KEEPALIVE, true).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {              ChannelPipeline p = socketChannel.pipeline();p.addLast(new MessageDecodeClient(255, 6, 1));// 处理来自服务端的响应信息socketChannel.pipeline().addLast(new TcpClientHandle());}});// 客户端开启ChannelFuture cf = bs.connect(ip, port).sync();byte[] respByte = new byte[6];//....以下为协议写入省略，请注意自行写出，若有问题，可以探讨// 发送客户端的请求cf.channel().writeAndFlush(Unpooled.copiedBuffer(respByte));// 等待直到连接中断cf.channel().closeFuture().sync();      }public static void main(String[] args) throws InterruptedException {new TcpClient("127.0.0.1", 8054).action();}}

以下为解码函数

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;/*** @author qianbo 协议重写成java*/
public class MessageDecodeClient extends LengthFieldBasedFrameDecoder {private static final int hsize = 6;public MessageDecodeClient(int maxFrameLength, int lengthFieldOffset, int lengthFieldLength) {super(maxFrameLength, lengthFieldOffset, lengthFieldLength);}@Overrideprotected Object decode(ChannelHandlerContext ctx, ByteBuf in) throws Exception {if (in == null) {return null;}if (in.readableBytes() < hsize) {return null;}in.markReaderIndex();byte magic = in.readByte(); //头部字节0x69byte titlelen = in.readByte(); //四字节大端ID号码int dataLength = in.readIntLE();dataLength += titlelen;if (in.readableBytes() < dataLength) {in.resetReaderIndex();return null;}//钱波 ：根据协议加上titlelen 和 数据lenbyte[] data = new byte[dataLength]; in.readBytes(data);String body = new String(data, "UTF-8");return body;}
}

处理的TcpClientHandle .java

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;public class TcpClientHandle extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {//  empty//可做一些工作}/** 建立连接时，返回消息*/@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {System.out.println("连接的客户端地址:" + ctx.channel().remoteAddress());ctx.writeAndFlush("客户端"+ InetAddress.getLocalHost().getHostName() + "成功与服务端建立连接！ \n");super.channelActive(ctx);}/*** 客户端断开*/@Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {System.out.println("channelInactive");}/*** 异常*/@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {cause.printStackTrace();}}

以上为主要的框架，读者可以根据基础自行写出，后面我也会补充写完整，希望能给您有所启发。

如何做一个国产数据库(七) 网络传输 java做订阅客户端相关推荐

如何做一个国产数据库(六) 网络传输 nodejs做测试客户端
如何做一个国产数据库一如何做一个国产数据库二如何做一个国产数据库三如何做一个国产数据库四如何做一个国产数据库五网络实战服务器我们再四中说过使用tcp进行协议的链接,对我们所定义的协议如果有 ...
如何做一个国产数据库(三)
一和二如何做一个国产数据库一如何做一个国产数据库二 1.数据结构重新定义再次重新定义数据结构 typedef struct sdata {uint32_t index;char vardata[ ...
如何做一个国产数据库(二)
如果做一个国产数据库一链接承接上文,继续 1.重新定义数据结构 typedef struct sdata {uint32_t index;char vardata[128]; }sdata;type ...
如何做一个国产数据库(四)
网络这次要用到网络了,存储的时候我们都使用网络来输入输出,当然,像本机是可以使用进程间通信的,不过为了简单,我们此次都使用tcp协议. 协议此次使用libuv来做网络的传输,我们首先定一个协议,做 ...
如何做一个国产数据库系统(一)
做国产数据库之二做一个国产数据库做一个数据库系统真的是要懂的是基础,各种基础,网络,文件系统,操作系统,性能,测试,各方面都要懂使用基本方法索引文件+数据文件+ B+ 树 ,hash空间如图 ...
动手做一个自组网的网络 - 操作系统内核
动手做一个自组网的网络 - 操作系统内核动手做一个自组网的网络 - 项目介绍动手做一个自组网的网络 - 硬件开发板动手做一个自组网的网络 - 操作系统内核动手做一个自组网的网络 - 网络协议栈 ...
[VB.NET]想做一个小界面，不知用什么做
<script type="text/javascript"></script> <script type="text/javascript ...
想做一个成功的女性，首先要做一个好女人
第一,我觉得一个好女人,一个真正最后通过一生的努力能够达到一个目标的女人,她是一个幸福的女人.所以说我觉得要做一个好女人.做一个幸福的女人,首先是要做一个有爱的女人. 因为只有爱她才是生命的核心,才是 ...
同r做一个窗口_怎样在触摸屏上做一个自定义的弹出窗口？
在触摸屏的应用中,一些故障.警告等提示信息通常是使用系统的报警窗口来实现.系统的报警窗口通常只有故障/警告的编号.日期时间及报警信息等内容,并且可以被折叠.这种千篇一律的报警窗口有时候并不能满足项目的 ...

如何做一个国产数据库(七) 网络传输 java做订阅客户端

server端协议定义

如何做一个国产数据库(七) 网络传输 java做订阅客户端相关推荐

最新文章

热门文章