12 篇博文 含有标签「Java」

不知不觉又有好久没写了，于是还是抽空写篇。

最近项目里有个数据统计的需求，在用户提交数据后就更新下统计结果，但是，用户可能批量提交，为了性能考虑，需要稍微延迟下再进行统计，并且短时间内的重复提交只统计一次即可。

为了实现简便，最后基于本地缓存+Redis ZSet实现。

前言​

在上一篇的基于Netty实现简单的Redis客户端 - 木然轩 - 文剑木然的网络日志中我介绍了如何使用Netty来编写一个简单的Redis客户端。在本篇中，将使用Netty实现一个简单的Redis服务端。

目标​

完整的Redis服务端的功能是很复杂的，由于是学习目的，这里只实现Redis最基本的一项功能，就是存取字符串，也就是下面的两个命令：

SET key value
GET key

实现​

由于Redis的协议在上一篇已经提过了，本篇就不再赘述了，直接上实现的过程。

前言​

Netty是Java中非常常用的网络库，它能自定义网络通信协议，从而实现非常丰富多样的网络功能。Redis是开发中非常常用的中间件，常用于缓存、分布式锁等场合，Redis的协议也非常简单。尽管Netty中自带了Redis的客户端，但是，为了学习，我们将不使用Netty自带的实现，而是自己动手写一个基础版本的Redis客户端。

目标​

Redis支持字符串、列表、集合等数据类型，考虑到是学习目的，只实现最最基础的功能，也就是设置与获取字符串的值。具体来说，就是下面两个命令：

# 设置指定key的值
SET key value
# 获取指定key的值
GET key

协议​

了解Redis协议​

可以从 Redis协议详细规范 来了解Redis的协议。Redis的协议是基于字符串的而不是二进制的，这为协议的处理带来了许多便利。

Netty 的核心组件​

Channel​

可以把 Channel 看作是传入(入站)或者传出(出站)数据的载体。因此，它可以被打开或者被关闭，连接或者断开连接。

回调​

一个回调其实就是一个方法，一个指向已经被提供给另外一个方法的方法的引用。这使得后者可以在适当的时候调用前者。回调在广泛的编程场景中都有应用，而且也是在操作完成后通知相关方最常见的方式之一。

Future​

Future 提供了另一种在操作完成时通知应用程序的方式。这个对象可以看作是一个异步操作的结果的占位符;它将在未来的某个时刻完成，并提供对其结果的访问。

ChannelFuture​

Netty 提供了它自己的实现—— ChannelFuture，用于在执行异步操作的时候使用。 ChannelFuture提供了几种额外的方法，这些方法使得我们能够注册一个或者多个ChannelFutureListener实例。 由ChannelFutureListener提供的通知机制消除了手动检查对应的操作是否完成的必要。 每个 Netty 的出站 I/O 操作都将返回一个ChannelFuture，也就是说，它们都不会阻塞。

Java NIO 由以下几个核心部分组成：

• Channels
• Buffers
• Selectors

Channel​

• FileChannel：从文件中读写数据
• DatagramChannel：能通过UDP读写网络中的数据
• SocketChannel：能通过TCP读写网络中的数据
• ServerSocketChannel：可以监听新进来的TCP连接，像Web服务器那样。对每一个新进来的连接都会创建一个SocketChannel