使用nginx+lua脚本读写redis缓存

配置

新建spring boot项目增加redis配置

        <dependency>

			<groupId>org.springframework.boot</groupId>

			<artifactId>spring-boot-starter-data-redis</artifactId>

		</dependency>

在需要缓存的地方增加redis缓存

package com.example.sharding.service;

import com.alibaba.fastjson.JSON;

import com.example.sharding.entity.Order;

import com.example.sharding.mapper.OrderMapper;

import com.fasterxml.jackson.databind.ObjectMapper;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;

import java.util.List;

@Service

@Transactional

public class OrderService {

    @Autowired

    private OrderMapper orderMapper;

    @Autowired

    private RedisTemplate redisTemplate;

    public Object findAll() throws IOException {

        List<Order> orders = orderMapper.selectAll();

        ObjectMapper mapper = new ObjectMapper();

        redisTemplate.opsForValue().set("orders",mapper.writeValueAsString(orders));

        return orders;

    }

    public void save(Order order) {

        orderMapper.insert(order);

        redisTemplate.opsForHash().put("order",order.getOrderId().toString(), JSON.parseObject(JSON.toJSONString(order)).toJSONString());

    }

    public void deleteAll() {

        orderMapper.deleteAll();

        redisTemplate.delete("order");

        redisTemplate.delete("orders");

    }

}

修改example.conf

server {

    listen       80;

    server_name  _;  

    location = /order {

	    default_type 'text/html';

	    lua_code_cache off;

	    content_by_lua_file C:\work\openresty-1.13.6.1-win32\example\lua/test_redis_basic.lua;

	}

    location /lua {

        default_type 'text/html';

        lua_code_cache off;

        content_by_lua_file C:\work\openresty-1.13.6.1-win32\example\lua/test.lua;

    }

    # 其他请求回源到tomcat

    location / {

    	proxy_pass http://tomcat/;

	}  

}

# 后端服务地址

upstream tomcat {

    server 127.0.0.1:8080 max_fails=5 fail_timeout=10s weight=1;

    keepalive 100;

}

修改test_redis_basic.lua文件

local function close_redis(red)

    if not red then

        return

    end

    local ok, err = red:close()

    if not ok then

        ngx.say("close redis error : ", err)

    end

end  

local function read_order()

    local resp = ngx.location.capture("/order/query", {

        method = ngx.HTTP_GET

    })

    if not resp then

        return

    end

    if resp.status ~= 200 then

        return

    end

    return resp.body

end  

local redis = require("resty.redis")

local cjson = require("cjson")  -- 引入json模块

--创建实例

local red = redis:new()

--设置超时（毫秒）

red:set_timeout(1000)

--建立连接

local ip = "127.0.0.1"

local port = 6379

local ok, err = red:connect(ip, port)

if not ok then

    ngx.say("connect to redis error : ", err)

    return close_redis(red)

end 

local res, err = red:auth("shiyuesoft")

if not res then

    ngx.say("failed to authenticate: ", err)

    return

end

--调用API获取数据

local resp, err = red:get("orders")

if not resp then

    ngx.say("get msg error : ", err)

    return close_redis(red)

end

--得到的数据为空处理

if resp == ngx.null then

    resp = read_order()  --回源到tomcat去查询

end

ngx.say(cjson.decode(resp))  --对返回的数据转换成json对象

close_redis(red)