之前提到，用RabbitMQ作为消息队列。但是这个东西实在太过高精尖，不懂erlang不会调优的情况下，很容易挂掉——基本上我这里试验结果跑不了半小时日志传输就断了。所以改用简单易行的redis来干这个活。 之前的lib里，有inputs/redis.rb和outputs/redis.rb两之前提到，用RabbitMQ作为消息队列。但是这个东西实在太过高精尖，不懂erlang不会调优的情况下，很容易挂掉——基本上我这里试验结果跑不了半小时日志传输就断了。所以改用简...
一、操作string 、list 、map 对象1、引入jar：jedis-2.1.0.jar 2、代码/** * @param args */ public static void main(String[] args) { //连接redis服务 Jedis jedis = new Jedis(192.168.88.15,6379); //密码验证-如果你没有设置redis密码可不验证即可使用一、操作string 、list 、map 对象1、引入jar：jedis-2.1.0.jar2、代码/*** @param args*/public static void main(String[] args) {//连接redis服务Jedis jedis = new Jed...
1.准备工作编译安装redis（我的安装目录/usr/loacl/tool）将redis-server 和 redis-cli 移到环境变量目录（/usr/loacl/bin）;给执行权限cp redis.conf 到配置目录（/etc/redis/redis.conf） 或者 做软连接；（我选择前者）注意： 对应的目录和权限，看其他需求2.创建systemctl 服务用service来管理服务的时候，是在/etc/init.d/目录中创建一个脚本文件，来管理服务的启动和停止，在systemctl中，也类似，文件目录有所不同，在/lib/...
1.哨兵放入后台执行:进入哨兵bin目录: ./redis-sentinel ../sentinel.conf(配置文件目录) --sentinel 2.自定义哨兵配置文件:vim sentinel.conf daemonize yes port 26380 (哨兵端口默认是26379) bind 0.0.0.0 (访问权限) dir "/home/redis3/bin" (启动redis-sentinel目录) logfile "/home/redis3/log/sentinel_log.log" (setinel日志目录) sentinel monitor redisA(自定义哨兵服务名字) 192.168.0.137 6379(定义master主机) 1(判断...
Redis整合SpringBoot 在测试中，推荐使用我们自己重写的RedisTemplate RedisTemplate 序列化问题 1.为何Redis整合Spring时需要在存储时序列化？在JAVA中，一个对象的信息一般并非连续的，在存储的时候我们会需要提炼为一个连续的数据串(通常是byte array数组或者字符串)，这个也正是序列化的字面意思。这样才能将你的对象信息存储起来，或者用于传输。 任何存储都需要序列化。只不过常规你在用DB一类存储的时候，这个事情DB帮你...
package com.ren.config;import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.databind.ObjectMapper; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframewor...
自定义redis的scan命令模糊查找key情景 主要情景，Spring boot 2.*使用自定义的scan方法代替RedisTemplate.keys(pattern)方法 代码 /*** scan* @param matchKey 要匹配的key的模糊表达式，例如 hpfm:lov:** @param count 步进值，过小效率会低一些，尽量与数据级匹配些，此处默认1000* private static final int SCAN_COUNT = 1000;* @return 所匹配到的key的Set集合*/ private Set<String> scan(String matchKey, In...
自定义redis工具jar包供其他项目直接使用 一、Redis常用存储操作实现（redis-util模块，该module最后会打包成jar供其他服务使用）1.引用相关依赖2.配置reids连接信息3.自定义序列化类，将存储在Redis的对象序列化为json格式4.开发相应的redis常用方法5.工具包开发完成，测试一下6.清除redis数据库连接信息二、创建一个consumer项目来引用redis-util工具包1.在consumer项目的pom.xml中添加reids-utils的依赖2.在consumer的applicati...
1 @Configuration2 public class RedisConfig {3 @Bean4 public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {5 RedisTemplate<String, Object> template = new RedisTemplate();6 template.setConnectionFactory(factory);7 Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);8 ObjectMappe...
Docker网络 理解Docker0 清空所有docker环境(反正下载也快) # 清空所有容器 docker rm -f $(docker ps -aq) # 清空所有镜像 docker rmi -f $(docker images -aq) # 清空所有挂载卷 docker volume prune# 网络命令须知 network [root@wulei home]# docker network --helpUsage: docker network COMMANDCOMMANDS:connect 将容器连接到网络create 创建一个网络disconnect 断开容器与网络的连接inspect 显示一个或多个...
我们需要根据IP去限制用户单位时间的访问次数，防止刷手机验证码,屏蔽注册机等，使用注解就非常灵活了 1 定义注解@Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) @Documented//最高优先级 @Order(Ordered.HIGHEST_PRECEDENCE) public @interface RequestLimit {/*** * 允许访问的次数，默认值MAX_VALUE*/int count() default Integer.MAX_VALUE;/*** * 时间段，单位为毫秒，默认值一分钟*/long time() default ...
对于分布式应用来说，最开始遇到的问题就是 session 的存储了，解决方案大致有如下几种使用 spring-session 它可以把 session 存储到你想存储的位置，如 redis，mysql 等 使用 JWTs ，它使用算法来验证 token 的合法性，是否过期，并且 token 无法被伪造，信息也是无法被篡改的本文内容主要说 spring-session 使用 redis 来存储 session ，实现原理，修改过期时间，自定义 key 等 spring-session 对于内部系统来说还是可以的，使用...
RedisSession （自定义）疯狂创客圈 Java 高并发【 亿级流量聊天室实战】实战系列 【博客园总入口 】架构师成长+面试必备之 高并发基础书籍 【Netty Zookeeper Redis 高并发实战 】疯狂创客圈 高并发 环境 视频，陆续上线：Windows Redis 安装（带视频） Linux Redis 安装（带视频） Windows Zookeeper 安装（带视频） Linux Zookeeper 安装（带视频）RabbitMQ 离线安装（带视频） Nacos 安装（带视频） ElasticSearch 安装, 带视频...
在我的SpringBoot项目中,当我使用以下方式注入RedisTemplate时,没关系.@Repository public class CommonDBDaoImpl implements CommonDBDao {@AutowiredRedisTemplate<String, Object> redisTemplate;.... }但是,当我将RedisTemplate与自定义实体/ DTO一起使用时,注入失败了..@Repository public class CommonDBDaoImpl implements CommonDBDao {@AutowiredRedisTemplate<String, PersonDTO> redisTemplate;.... }public PersonDTO ...
1.简述目的：一定时间内，同样的请求（业务参数相同）访问同一个接口，则只能成功一次，其余被拒绝。2.引入redis支持 因为需要通过redis的setnx确保只有一个接口能够正常访问，所以需要引入redis。 2.1.pom.xml <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><exclusions><!-- 需要排除哪些包由具体项目觉得 --><exclusion><artifactId>spring-boot-starter-lo...