控制器：publicfunction lists(Request $request){$where = [];//条件搜索if(!empty($request[‘type‘])){$where[‘type‘] = $request[‘type‘];}if(!empty($request[‘title‘])){$where[‘title‘] = $request[‘title‘];}if(!empty($request[‘author‘])){$where[‘author‘] = $request[‘author‘];}if($where){//根据条件进行查询$data = Articles::lists2($where);$page = $data->currentPage();//当前页$num = $data-...
Redis 做分布式锁分布式锁也算是 Redis 比较常见的使用场景。问题场景：例如一个简单的用户操作，一个线城去修改用户的状态，首先从数据库中读出用户的状态，然后在内存中进行修改，修改完成后，再存回去。在单线程中，这个操作没有问题，但是在多线程中，由于读取、修改、存 这是三个操作，不是原子操作，所以在多线程中，这样会出问题。对于这种问题，我们可以使用分布式锁来限制程序的并发执行。基本用法分布式锁实现的思路很简...
最近在项目中遇到了类似“秒杀”的业务场景，在本篇博客中，我将用一个非常简单的demo，阐述实现所谓“秒杀”的基本思路。 业务场景所谓秒杀，从业务角度看，是短时间内多个用户“争抢”资源，这里的资源在大部分秒杀场景里是商品；将业务抽象，技术角度看，秒杀就是多个线程对资源进行操作，所以实现秒杀，就必须控制线程对资源的争抢，既要保证高效并发，也要保证操作的正确。一些可能的实现刚才提到过，实现秒杀的关键点是控制线...
前言最近开发了几个微服务上线了，发现定时任务执行了很多次，查看rancher发现这几个微服务都是多实例的，也就是说定时任务执行了多次，恰好所用框架中使用的是Redisson, 正好记录下使用Redission实现分布式锁正文配置添加Redisson依赖 <dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.6.5</version></dependency>添加配置类import org.redisson.Redisson; import org.redisson.a...
导读 SHA-1算法是第一代“安全散列算法”的缩写，其本质就是一个Hash算法。SHA系列标准主要用于数字签名，生成消息摘要，曾被认为是MD5算法的后继者。如今SHA家族已经出现了5个算法。Redis使用的是SHA-1，它能将一个最大2^64比特的消息，转换成一串160位的消息摘要，并能保证任何两组不同的消息产生的消息摘要是不同的。虽然SHA1于早年间也传出了破解之道，但作为SHA家族的第一代算法，对我们仍然很具有学习价值和指导意义。...
目录项目的Github地址需求介绍搭建Redis集群环境下面先描述单机版redis的安装下面将进行Redis3主3从集群环境搭建基于SOA架构, 创建门户ashop-portal-web门户项目实现门户首页商品类目显示实现门户首页大广告轮播实现商品类目缓存实现大广告缓存, 缓存同步缓存同步项目的Github地址需求介绍为了缩短用户看到首页信息的时间, 我们把首页显示的类目信息, 广告等数据放到Redis缓存中, 这样就不用通过耗时的数据库操作获取数据, 而是直接...
思维导图前言在很多业务情况下，我们都会在系统中加入redis缓存做查询优化。如果数据库数据发生更新，这时候就需要在业务代码中写一段同步更新redis的代码。这种数据同步的代码跟业务代码糅合在一起会不太优雅，能不能把这些数据同步的代码抽出来形成一个独立的模块呢，答案是可以的。架构图canal是一个伪装成slave订阅mysql的binlog，实现数据同步的中间件。上一篇文章《canal入门》我已经介绍了最简单的使用方法，也就是tcp模式。...
利用redis的乐观锁，实现秒杀系统的数据同步（基于watch实现）用户一：import redisconn = redis.Redis(host=‘127.0.0.1‘,port=6379)# conn.set(‘count‘,1000) with conn.pipeline() as pipe:# 先监视，自己的值没有被修改过conn.watch(‘count‘)# 事务开始 pipe.multi()old_count = conn.get(‘count‘)count = int(old_count)input(‘我考虑一下‘)if count > 0: # 有库存pipe.set(‘count‘, count - 1)# 执行，把所有...
1：下载wget http://download.redis.io/releases/redis-3.2.8.tar.gz1下载指定版本，可以登录https://redis.io/download查看2：安装tar zxvf redis-3.2.8.tar.gzcd redis-3.2.8makesudo make install1234这时Redis 的可执行文件被放到了/usr/local/bin3：配置sudo mkdir /etc/redissudo cp redis.conf /etc/redis/6379.confsudo cp utils/redis_init_script /etc/redis/1234：运行和关闭cd /etc/redis1#使用root权限运行sudo ./red...
一、工作中因为要使用到Tomcat集群部署，此时就涉及到了Session共享问题，主要有三种解决方案：1、使用数据库来存储Session2、使用Cookie来存储Session3、使用Redis来存储Sesssion 二、本文中主要讲一下第3种方案，也就是使用Redis来存储Session，Github中已经有该开源组件（tomcat-redis-session-manager），下面讲一下配置的步骤1、配置tomcat配置文件context.xml<Valve className="com.orangefunction.tomcat.redissessions.Red...
新开发的系统需要控制每个时刻回收缓存的GC线程有且只有一个在运行，如果有多个线程同时运行，会造成系统崩溃。如果只有一个JVM进程那么很好办，简单的借助synchronized关键字就行了。可是我的系统要部署在多台服务器，每台服务器上部署多个实例上。而synchronized仅仅在单进程里有用。 考虑借助共享数据源redis实现功能。 redis提供一个方法，SETNX key value。将 key 的值设为 value ，当且仅当 key 不存在。若给定的 key ...
Keepalived+nginx+redis主从+tomcat一机多实例实现会话共享 2014-09-09 14:14:25标签：会话共享主从原创作品，允许转载，转载时请务必以超链接形式标明文章 原始出处 、作者信息和本声明。否则将追究法律责任。http://lovelace.blog.51cto.com/1028430/1550198### keepalived配置### nginx安装培训- 安装nginx123``` cppyum install nginx -y```- 调整nginx配置文件1234567891011121314151617181920212223242526272829303132333435...
应用场景最近在公司做项目，需要对聊天内容进行存储，考虑到数据库查询的IO连接数高、连接频繁的因素，决定利用缓存做。从网上了解到redis可以对所有的内容进行二进制的存储，而java是可以对所有对象进行序列化的，序列化的方法会在下面的代码中提供实现。序列化这里我编写了一个java序列化的工具，主要是对对象转换成byte[]，和根据byte[]数组反序列化成java对象；主要是用到了ByteArrayOutputStream和ByteArrayInputStream；需要...
一个简单快速的将MySQL的数据迁移到Redis中并且以hash方式存储，数据的存储需要遵守redis的通讯协议(官方连接 http://redis.io/topics/mass-insert)，如: *3 CR LF //三个字段 $3 CR LF //第一个字段 ‘set’ 有3个字节 SET CR LF //字段内容set $4 CR LF //第二个字段key1有4个字节 key1 CR LF //字段二内容 mykey $4 CR LF //第三个字段有4个字节 val1 CR LF //字段三内容 val1 结果：set key1 val1...
前言 开心一刻小白问小明：“你前面有一个5米深的坑，里面没有水，如果你跳进去后该怎样出来了？”小明：“躺着出来呗，还能怎么出来？”小白：“为什么躺着出来？”小明：“5米深的坑，还没有水，跳下去不死就很幸运了，残是肯定会残的，不躺着出来，那能怎么出来？”小白：“假设没死也没残呢？”小明：“你当我超人了？ 那也简单，把脑子里的水放出来就可以漂出来了。”小白：“你脑子里有这么多水吗？”小明：“我脑子里没那...