Java Spring mvc は Redis および Redis クラスターを操作します-jsチュートリアル-php.cn

Redis クラスターの構築については、私の他の記事「Redis クラスターの構築と簡単な使い方」を参照してください

Redis とは何か、何ができるのか

Redis は、オープンソース (BSD ライセンス) のメモリに保存されたデータ構造サーバーであり、データベース、キャッシュ、メッセージキューブローカーとして使用されます。文字列、ハッシュテーブル、リスト、セット、順序付きセット、ビットマップ、ハイパーログログ、およびその他のデータ型をサポートします。組み込みのレプリケーション、Lua スクリプト、LRU エビクション、トランザクション、およびさまざまなレベルのディスク永続化機能により、Redis Sentinel による高可用性と Redis Cluster による自動パーティショニングが提供されます。 (Redis公式Webサイトより抜粋)

Redisはインメモリデータベースとして、現代のインターネットWebシステムにおいても主にキャッシュとして使用されています。大規模なインターネット Web システムには高いパフォーマンスが要求され、フロントエンドとデータ層の間にデータキャッシュを追加することが重要な手段の 1 つとなっています。その 2 つのテクノロジは Redis と Memcached です。それはこの記事の内容ではありません。この記事では主に、Java Web が Redis と Redis クラスターをどのように操作するかについて説明します。

一般的な Java プログラムは Redis を操作します

Redis は複数の言語でクライアントを提供します。Java で最も人気のあるものは Jedis です。にアクセスして、ソースコードとその使用方法を確認してください。現在、Jedis の最新バージョンは 2.9.0 です。スタンドアロンマシンでもクラスターでも、Jedis には非常に詳細な手順とサンプルコードが用意されています。ここでは簡単に説明します。パッケージ管理に Maven を使用する場合、次のように jedis パッケージを参照する必要があります。この例では、次のように最新の 2.9.0 バージョンを使用します。

Spring mvc Redis での操作もちろん、最初に Spring mvc フレームワークをセットアップする必要があります。以下は Spring mvc 環境が構築されていることを前提としています。この例では、Spring バージョンは 4.3.2 RELEASE です。 Spring に関する Maven リファレンスは次のとおりです:

      redis.clients      jedis      2.9.0

ログイン後にコピー

スタンドアロンで Redis を操作します

インジェクションを実装するには Jedis のみを使用します (spring-data-redis の下のリファレンスとは異なります)

前の JedisClient コードを取得して引用するだけです。 Redis サービスへのアクセスは Spring mvc に統合できます。実装する必要があるのは 1 つだけです。 Service コードは以下の通りです:

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
 
/**
 * Created by fengdezitai on 2016/10/9.
 */
public class JedisClient {
 
    private static final String host= "192.168.31.121";
 
    private static final JedisClient jedisClient = new JedisClient();
 
    private Jedis jedis = null;
    /**
     * 私有构造函数
     */
    private JedisClient(){}
 
    public static JedisClient getInstance(){
        return jedisClient;
    }
 
    private JedisPoolConfig getPoolConfig(){
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxIdle(10);
        jedisPoolConfig.setMaxTotal(100);
        jedisPoolConfig.setMaxWaitMillis(3000);
        return jedisPoolConfig;
    }
 
    /**
     * 添加
     * @param key
     * @param value
     * @return
     * @throws Exception
     */
    public Boolean add(String key,String value) throws Exception{
        JedisPool pool = new JedisPool(getPoolConfig(),host);
        Jedis jedis = null;
        try {
            jedis = pool.getResource();
            if(jedis.exists(key)){
                throw new Exception(String.format("key (%s) 已存在 ",key));
            }
            jedis.set(key,value);
 
        }catch (Exception e){
            throw e;
        }
        finally {
            if(jedis!=null){
                jedis.close();
            }
        }
        pool.destroy();
        return true;
    }
 
    /**
     * 获取值
     * @param key
     * @return
     * @throws Exception
     */
    public String get(String key) throws Exception{
        JedisPool pool = new JedisPool(getPoolConfig(),host);
        Jedis jedis = null;
        String result = "";
        try {
            jedis = pool.getResource();
            result = jedis.get(key);
        }catch (Exception e){
            throw e;
        }
        finally {
            if(jedis!=null){
                jedis.close();
            }
        }
        pool.destroy();
        return result;
    }
 
    public static void main(String[] args) {
        JedisClient jedisClient = JedisClient.getInstance();
        try {
            /*Boolean result = jedisClient.add("hello", "redis1");
            if(result){
                System.out.println("success");
            }*/
 
            System.out.println(jedisClient.get("hello"));
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

ログイン後にコピー

Controller は以下のように実装されています:

import redis.clients.jedis.*;
import java.util.HashSet;
import java.util.Set;
 
/**
 * Created by fengdezitai on 2016/10/13.
 */
public class JedisClusterClient {
 
    private static int count = 0;
 
    private static final JedisClusterClient redisClusterClient = new JedisClusterClient();
 
    /**
     * 私有构造函数
     */
    private JedisClusterClient() {}
 
    public static JedisClusterClient getInstance() {
        return redisClusterClient;
    }
 
    private JedisPoolConfig getPoolConfig(){
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(1000);
        config.setMaxIdle(100);
        config.setTestOnBorrow(true);
        return config;
    }
 
    public void SaveRedisCluster() {
        Set jedisClusterNodes = new HashSet();
        jedisClusterNodes.add(new HostAndPort("192.168.31.245", 7000));
        jedisClusterNodes.add(new HostAndPort("192.168.31.245", 7001));
        jedisClusterNodes.add(new HostAndPort("192.168.31.245", 7002));
        jedisClusterNodes.add(new HostAndPort("192.168.31.210", 7003));
        jedisClusterNodes.add(new HostAndPort("192.168.31.210", 7004));
        jedisClusterNodes.add(new HostAndPort("192.168.31.210", 7005));
 
        JedisCluster jc = new JedisCluster(jedisClusterNodes,getPoolConfig());
        jc.set("cluster", "this is a redis cluster");
        String result = jc.get("cluster");
        System.out.println(result);
    }
 
    public static void main(String[] args) {
        JedisClusterClient jedisClusterClient = JedisClusterClient.getInstance();
        jedisClusterClient.SaveRedisCluster();
    }
}

ログイン後にコピー

統合には spring-data-redis パッケージを使用します

上記は私が実装したインジェクションです。ここでは spring-data-redis を使用しています。 Maven パッケージへの参照は次のとおりです。バージョンは最新バージョン 1.7.2.RELEASE:

4.3.2.RELEASE 

    
          org.springframework      spring-core      ${spring.version}                        commons-logging          commons-logging                   
          org.springframework      spring-web      ${spring.version}     
          org.springframework      spring-oxm      ${spring.version}     
          org.springframework      spring-tx      ${spring.version}     
          org.springframework      spring-jdbc      ${spring.version}     
          org.springframework      spring-webmvc      ${spring.version}                        commons-logging          commons-logging                   
          org.springframework      spring-aop      ${spring.version}     
          org.springframework      spring-context-support      ${spring.version}     
 
          org.springframework      spring-test      ${spring.version}

ログイン後にコピー

spring-data-redis を使用すると、インジェクションプロセスを実装する必要がなくなります。提供される構成の一部を通じて、接続プール構成、RedisTemplate 構成、JedisConnectionFactory 構成を実現できます。JedisConnectionFactory を通じて、接続プールのパラメーター、Redis サーバー、ポート、パスワード、タイムアウト、データベースインデックスなどを構成できます。は挿入された Bean であり、RedisTemplate によって自動的に挿入されたエンティティを使用して、一連の Redis 操作を実行できます。詳細については、「構成」を参照してください。

redis サービス属性構成ファイル:

import org.springframework.stereotype.Service;
import util.JedisClient;
 
/**
 * Created by fengdezitai on 2016/10/9.
 */
@Service
public class RedisService {
 
    public String get(String key) throws Exception{
        JedisClient jedisClient = JedisClient.getInstance(); //上面实现的JedisClient
        String result = "";
        try {
            result = jedisClient.get("hello");
        }catch (Exception e){
            throw e;
        }
        return result;
    }
}

ログイン後にコピー

spring-data-redis xml 構成ファイルcontext.xml:

@Controller
@RequestMapping(value = "redisAllInOne")
public class RedisAllInOneController {
 
    @Autowired
    private RedisService redisService;
 
    @RequestMapping(value = "get",method = RequestMethod.GET)
    @ResponseBody
    public Object getByMyService(String key){
        try {
            String result = redisService.get(key);
            return result;
        }catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }
}

ログイン後にコピー

次に、Spring 構成ファイルで上記のファイルを引用します:

      org.springframework.data      spring-data-redis      1.7.2.RELEASE

ログイン後にコピー

上記の構成を説明します:

poolConfig は、redis 接続プールを構成し、1 つの JedisConnectionFactory と RedisTemplate を 1 つの JedisConnectionFactory に対応させます。このようにして、一貫性のないタイムアウト要件、データベース 0 ～ 15 に異なるデータを保存できるなど、シナリオに応じて異なる Redis 接続を構成できます。ここではデータベース 1 と 2 が構成されており、commonRedisTemplate を呼び出すとデータベース 1 に保存され、cacheRedisTemplate を呼び出すとデータベース 2 に保存されます。

その後、次のように、これら 2 つの RedisTemplate をサービスレイヤーに挿入して参照できます:

redis.maxIdle=300
redis.maxWait=3000
redis.testOnBorrow=true
redis.host=192.168.31.121
redis.port=6379
redis.password=password
redis.timeout=3000

ログイン後にコピー

最後にコントローラーで呼び出します

ログイン後にコピー

Redis クラスターを操作するには

Jedis のみを使用して注入を実装します (以下の Spring リファレンス) -data-redis)

前の JedisClusterClient コードを取得して参照するだけで、Redis にアクセスするための Service を実装するだけで、Spring mvc に統合できます。 Service コードは次のとおりです:

ログイン後にコピー

最後に、コントローラーで実装された Service を呼び出します

import org.apache.commons.lang3.StringUtils;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Repository;
 
import javax.annotation.Resource;
import java.io.*;
 
@Repository
public class RedisCache {
　　
    @Resource(name = "cacheRedisTemplate")
    private RedisTemplate

ログイン後にコピー

統合には spring-data-redis パッケージを使用します

Spring および spring-data-redis Maven パッケージの参照は前と同じですspring-data-redis 1.7.2.RELEASE の理由は、現在この最新バージョンのみがクラスター操作をサポートしているためです。

redis クラスターサービス属性の設定

@Autowired
private RedisCache redisCache;
 
 
@RequestMapping(value = "get", method = RequestMethod.GET)
@ResponseBody
public Object getByMyService(String key) {
    try {
        String result = redisService.get(key);
        return result;
    } catch (Exception e) {
        e.printStackTrace();
    }
    return null;
}
 
@RequestMapping(value = "save", method = RequestMethod.GET)
@ResponseBody
public Object save() {
    Token token = new Token();
    token.setAccess_token("token");
    token.setExpires_in(1000);
    try {
        redisCache.put("token", token);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return "ok";
}

ログイン後にコピー

spring-data-redis xml クラスター設定ファイル redis-cluster-context.xml

import org.springframework.stereotype.Service;
import util.JedisClusterClient;
 
/**
 * Created by fengdezitai on 2016/10/13.
 */
@Service
public class RedisClusterService {
 
    public void save() throws Exception{
        //调用 JedisClusterClient 中的方法
        JedisClusterClient jedisClusterClient = JedisClusterClient.getInstance();
        try {
            jedisClusterClient.SaveRedisCluster();
        }catch (Exception e){
            throw e;
        }
    }
}

ログイン後にコピー

は後で Spring 設定ファイルで参照されます

@Controller
@RequestMapping(value = "redisCluster")
public class RedisClusterController {
 
    @Autowired
    private RedisClusterService redisClusterService;
 
    @RequestMapping(value = "save",method = RequestMethod.GET)
    @ResponseBody
    public Object save(){
        try{
            redisClusterService.save();
        }catch (Exception e){
            e.printStackTrace();
            return String.format("error: %s",e.getMessage());
        }
        return "ok";
    }
}

ログイン後にコピー

上記の設定の説明:

poolConfigは接続プールの構成、redisClusterConfig は Redis クラスターの各ノードを構成します (ノードのホストとポートは属性構成ファイルに記述するのが最適です)。クラスターの構築については、私の他のブログを参照してください。以下はスタンドアロン構成と同じ、JedisConnectionFactory と RedisTemplate のペアです。

その後、この RedisTemplate をサービス層に挿入して参照できます。コードは次のとおりです:

redis.maxIdle=300
redis.maxWait=3000
redis.testOnBorrow=false
redis.timeout=3000

ログイン後にコピー

最後に、コントローラーで呼び出すだけです

<br/>

ログイン後にコピー

注:

バージョンの問題、spring-data-redis を使用して Reid クラスターを統合する場合、クラスター上の操作が含まれるのは spring-data-redis の最新バージョン 1.7 のみであり、最新の spring-data-redis の一部の関数はクラスターに適していません。 Spring mvc バージョンにも制限があるので、Spring mvc の上位バージョンを選択するようにしてください。

格納された値がエンティティオブジェクトの場合は、Serializable インターフェイスを実装する必要があります

[関連する推奨事項]

1. Spring フレームワークアノテーションの使用コード例の詳細な説明

2. Spring および Java トランザクション管理学習 Hibernate コードの詳しい説明