Spring boot 配置多个redis的方法示例

<?xml version= "1.0" encoding= "utf-8" ?>

<project xmlns= "http://maven.apache.org/pom/4.0.0" xmlns:xsi= "http://www.w3.org/2001/xmlschema-instance"

  xsi:schemalocation= "http://maven.apache.org/pom/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >

  <modelversion> 4.0 . 0 </modelversion>

  <groupid>me.deweixu</groupid>

  <artifactid>muti-redis</artifactid>

  <version> 0.0 . 1 -snapshot</version>

  <packaging>jar</packaging>

  <name>muti-redis</name>

  <description>config mutiple redis host</description>

  <parent>

   <groupid>org.springframework.boot</groupid>

   <artifactid>spring-boot-starter-parent</artifactid>

   <version> 2.0 . 4 .release</version>

   <relativepath/> <!-- lookup parent from repository -->

  </parent>

  <properties>

   <project.build.sourceencoding>utf- 8 </project.build.sourceencoding>

   <project.reporting.outputencoding>utf- 8 </project.reporting.outputencoding>

   <java.version> 1.8 </java.version>

  </properties>

  <dependencies>

   <dependency>

    <groupid>org.springframework.boot</groupid>

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

   </dependency>

   <dependency>

    <groupid>org.springframework.boot</groupid>

    <artifactid>spring-boot-starter-test</artifactid>

    <scope>test</scope>

   </dependency>

  </dependencies>

  <build>

   <plugins>

    <plugin>

     <groupid>org.springframework.boot</groupid>

     <artifactid>spring-boot-maven-plugin</artifactid>

    </plugin>

   </plugins>

  </build>

</project>

spring.redis.host=localhost

spring.redis.port= 6379

package me.deweixu.mutiredis;

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

import org.springframework.boot.commandlinerunner;

import org.springframework.boot.springapplication;

import org.springframework.boot.autoconfigure.springbootapplication;

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

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

@springbootapplication

public class mutiredisapplication implements commandlinerunner {

  @autowired

  stringredistemplate stringredistemplate;

  @override

  public void run(string... args) throws exception {

   boundvalueoperations op = stringredistemplate.boundvalueops( "person" );

   op.set( "deweixu" );

  }

  public static void main(string[] args) {

   springapplication.run(mutiredisapplication. class , args);

  }

}

$ redis-cli

127.0 . 0.1 : 6379 > keys *

1 ) "person"

127.0 . 0.1 : 6379 > get person

"deweixu"

127.0 . 0.1 : 6379 >

public stringredistemplate() {

  redisserializer<string> stringserializer = new stringredisserializer();

  this .setkeyserializer(stringserializer);

  this .setvalueserializer(stringserializer);

  this .sethashkeyserializer(stringserializer);

  this .sethashvalueserializer(stringserializer);

}

@autowired

stringredistemplate stringredistemplate;

@override

public void run(string... args) throws exception {

  boundvalueoperations op = stringredistemplate.boundvalueops( "person" );

  op.set( new person( "deiweixu" , 22 ));

}

public static void main(string[] args) {

  springapplication.run(mutiredisapplication. class , args);

}

@bean

jedisconnectionfactory jedisconnectionfactory() {

  return new jedisconnectionfactory();

}

@bean

redistemplate<string, object> firstredistemplate() {

  redistemplate<string, object> redistemplate = new redistemplate<>();

  objectmapper om = new objectmapper();

  om.setvisibility(propertyaccessor.all, jsonautodetect.visibility.any);

  om.enabledefaulttyping(objectmapper.defaulttyping.non_final);

  om.configure(deserializationfeature.fail_on_unknown_properties, false );

  genericjackson2jsonredisserializer genericjackson2jsonredisserializer = new genericjackson2jsonredisserializer(om);

  redistemplate.setkeyserializer( new stringredisserializer());

  redistemplate.setvalueserializer(genericjackson2jsonredisserializer);

  redistemplate.sethashkeyserializer( new stringredisserializer());

  redistemplate.sethashvalueserializer(genericjackson2jsonredisserializer);

  redistemplate.setconnectionfactory(jedisconnectionfactory());

  return redistemplate;

}

@autowired

redistemplate<string, object> redistemplate;

@override

public void run(string... args) throws exception {

  boundvalueoperations<string, object> op = redistemplate.boundvalueops( "person" );

  people people = new people();

  people.setage( 26 );

  people.setname( "deweixu" );

  op.set(people);

  people getpeople = (people) op.get();

  system.out.println(getpeople.getname() + "," + getpeople.getage());

}

<dependency>

  <groupid>com.fasterxml.jackson.core</groupid>

  <artifactid>jackson-databind</artifactid>

  <version> 2.9 . 0 </version>

</dependency>

<dependency>

  <groupid>redis.clients</groupid>

  <artifactid>jedis</artifactid>

</dependency>

127.0 . 0.1 : 6379 > get person

"[\"me.deweixu.mutiredis.entity.people\",{\"name\":\"deweixu\",\"age\":26}]"

127.0 . 0.1 : 6379 >

@bean

redistemplate<string, object> secondredistemplate() {

  redistemplate<string, object> redistemplate = new redistemplate<>();

  objectmapper om = new objectmapper();

  om.setvisibility(propertyaccessor.all, jsonautodetect.visibility.any);

  om.enabledefaulttyping(objectmapper.defaulttyping.non_final);

  om.configure(deserializationfeature.fail_on_unknown_properties, false );

  genericjackson2jsonredisserializer genericjackson2jsonredisserializer = new genericjackson2jsonredisserializer(om);

  redistemplate.setkeyserializer( new stringredisserializer());

  redistemplate.setvalueserializer(genericjackson2jsonredisserializer);

  redistemplate.sethashkeyserializer( new stringredisserializer());

  redistemplate.sethashvalueserializer(genericjackson2jsonredisserializer);

  // 这里的 redis 信息也是可以写入配置文件，用 @value 读入

  // 这里是单机的配置，看看源代码还可以配置集群和哨兵模式

  redisstandaloneconfiguration configuration = new redisstandaloneconfiguration( "localhost" , 6379 );

  jedisconnectionfactory factory = new jedisconnectionfactory(configuration);

  redistemplate.setconnectionfactory(factory);

  return redistemplate;

}

@autowired

redistemplate<string, object> firstredistemplate;

@autowired

redistemplate<string, object> secondredistemplate;

@override

public void run(string... args) throws exception {

  boundvalueoperations<string, object> op = firstredistemplate.boundvalueops( "person" );

  people people = new people();

  people.setage( 26 );

  people.setname( "deweixu" );

  op.set(people);

  boundvalueoperations<string, object> secondop = secondredistemplate.boundvalueops( "person" );

  people getpeople = (people) secondop.get();

  system.out.println(getpeople.getname() + "," + getpeople.getage());

}