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 インターフェイスを実装する必要があります
[関連する推奨事項]
2. Spring および Java トランザクション管理学習 Hibernate コードの詳しい説明
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
