spring-data-redis实现，spring redisson

Redis实现不可靠发布/订阅功能

1、redis发布订阅还是不太适合商用，并不支持消息重试，即便重新注册上了，之前的消息也丢了。

2、redis-pub/sub断电就清空，而使用redis-list作为消息推送虽然有持久化，但是又太弱智，也并非完全可靠不会丢。

3、虽然Redis提供了发布/订阅的功能，但是并不完善，导致基本没有合适的场景能够使用。PubSub缺点：直到Redis0出现之后，出现了Stream这种数据结构，才终于完善了Redis的消息机制 。

4、将no-appendfsync-on-rewrite的配置设为yes可以缓解这个问题，设置为yes表示rewrite期间对新写操作不fsync，暂时存在内存中，等rewrite完成后再写入。最好是不开启Master的AOF备份功能。

5、有两种方法：Redis自带的PUB/SUB机制，即发布-订阅模式。

6、Agora Games就是一个很好的例子，用Ruby实现的，它的排行榜就是使用Redis来存储数据的，你可以在这里看到。发布/订阅 最后（但肯定不是最不重要的）是Redis的发布/订阅功能。发布/订阅的使用场景确实非常多。

相关问答

Q1: Spring+Boot对Redis整合时,需要添加对应的依赖启动器是什么?

Spring Boot整合Redis我们需要添加依赖的jar包，spring-boot-starter-data-redis中包含spring和redis相关的jar包，jedis作为redis的客户端也需要添加到工程中，Spring Boot的版本信息在父pom中已指定，子模块中的spring相关的jar包无需另外指定。

首先我们创建一个Spring Boot x的项目，在application.properties配置文件中添加Redis的配置，Spring和Redis的整合可以参考我其他的文章，此处不再详解。我们设置服务端口server.port为8080端口用于启动第一个服务。

升级对象是一套JavaWeb开发框架，有自己的父工程来控制依赖包的版本，在决定升级Java版本与Springboot版本后，父工程的pom文件中的相关依赖包版本需要更新。

Q2: increment()函数

1、本文使用spring封装的spring-data-redis进行操作，在对某key进行increment()方法实现计数器，此计数器可以用在分布式当中，不会局限于某一jvm。

2、this指的是此对象自身。也就是哪个对象里面用this就指的是哪个对象。this.increment()是指此对象的方法。

3、在increment_global中，我们使用了global关键字来声明global_var是一个全局变量，并对其进行递增操作。在outer中，我们定义了一个内部函数inner，并使用nonlocal关键字声明x是外部函数outer中定义的变量。

Q3: SpringBoot整合SpringSeesion实现Redis缓存

将Spring Session集成到Spring Boot框架中并使用Redis进行缓存是目前非常流行的解决方案，接下来就跟着我一起学习吧。

其中，getKeysByPattern是基于redis的scan命令实现。Redisson的分布式RBucket Java对象是一种通用对象桶，可以用来存放任意类型的对象。除了同步接口外，还提供异步(Async)、反射式(Reactive)和RxJava2标准的接口。

当有新数据的时候，我们再及时更新它，一般流程是先查询缓存，查到了直接返回缓存数据，查不到再走数据库，然后再刷回缓存。

添加Spring session的包，而Spring session 是将HttpSession存放在Redis中，因此需要添加Redis的包。我们这里是用了Spring boot进行配置Rdies。使用@EnableRedisHttpSession注解进行配置启用使用Spring session。

首先，spring-boot-autoconfigure里的spring.factories里有提到SessionAutoConfiguration。springboot就会自动加载该类(不知道为什么会自动加载的话，建议先百度springboot自动加载原理)。

Q4: 到底如何在spring中使用redis

在配置文件中添加了 Redis 的配置信息之后，就可以在 Spring Boot 应用程序中使用 Redis 了。可以使用 `@Autowired` 注解注入 `RedisTemplate` 或 `StringRedisTemplate` 对象，然后使用这些对象操作 Redis 数据库。

spring.redis.host=localhost spring.redis.port=6379 这样以来，最简单的spring boot + redis实现session共享就完成了，下面进行下测试。

每个Redisson对象实例都会有一个与之对应的Redis数据实例，可以通过调用getName方法来取得redis数据实例的名称(key)，所有于Redis key相关的操作都归纳在RKeys这个接口里。

强烈建议阅读 Spring-session原理 的spring-session重写servlet request 及 redis实现存储相关问题另外在写作中，适当参考了下面的文章。

Q5: 使用spring-data-redis集群redis,

如果用的是前者，配置是需要连接sentinel端口的（默认26379），不是连接redis端口（6379）。或者把spring相关配置文件贴出来一下。

对user：{user1}：ids和user：{user1}：tweets，其hash值都等同于sha1(user1)。Spring Data Redis的官方文档 也建议在使用Cluster模式的时候使用Hash Tag，这样可以让对象的属性位于同一个分片，方便查找和计算。

目前spring-data-redis到底支不支持redis集群的 这样做的效果就是在比较哈希码的时候不能进行判断，因为每个对象返回的哈希码都是1，每次都必须要经过比较equals()方法后才能进行判断是否重复，这当然会引起效率的大大降低。

首先，spring-boot-autoconfigure里的spring.factories里有提到SessionAutoConfiguration。springboot就会自动加载该类(不知道为什么会自动加载的话，建议先百度springboot自动加载原理)。

spring-data-redis实现的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于spring redisson、spring-data-redis实现的信息别忘了在本站进行查找喔。