springboot连接Redis的教程详解

spring.redis.host= 192.168 . 5.132

spring.redis.port= 6379

package com.myspringboot.redis;

import org.springframework.boot.springapplication;

import org.springframework.boot.autoconfigure.springbootapplication;

import org.springframework.context.configurableapplicationcontext;

@springbootapplication

public class demoapplication {

   public static void main(string[] args) {

     configurableapplicationcontext configurableapplicationcontext = springapplication.run(demoapplication. class , args);

     redistest redistest = configurableapplicationcontext.getbean(redistest. class );

     redistest.testredis();

   }

}

package com.myspringboot.redis;

import org.springframework.context.annotation.bean;

import org.springframework.context.annotation.configuration;

import org.springframework.data.redis.connection.redisconnectionfactory;

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

import org.springframework.data.redis.serializer.jackson2jsonredisserializer;

@configuration

public class mytemplate {

   @bean

   public stringredistemplate getmytemplate(redisconnectionfactory redisconnectionfactory){

     stringredistemplate stringredistemplate = new stringredistemplate(redisconnectionfactory);

     stringredistemplate.sethashvalueserializer( new jackson2jsonredisserializer<object>(object. class ));

     return stringredistemplate;

   }

}

package com.myspringboot.redis;

import com.fasterxml.jackson.databind.objectmapper;

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

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

import org.springframework.data.redis.connection.message;

import org.springframework.data.redis.connection.messagelistener;

import org.springframework.data.redis.connection.redisconnection;

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

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

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

import org.springframework.data.redis.hash.jackson2hashmapper;

import org.springframework.data.redis.serializer.jackson2jsonredisserializer;

import org.springframework.stereotype.component;

import java.util.map;

@component

public class redistest {

   @autowired

   redistemplate redistemplate;

   @autowired

   stringredistemplate stringredistemplate;

   @autowired

   objectmapper objectmapper;

   // 自定义模板

   @autowired

   @qualifier ( "getmytemplate" )

   stringredistemplate mystringredistemplate;

   public void testredis()  {

     //redis中直接查看时，乱码

     redistemplate.opsforvalue().set( "key1" , "hello1" );

     system.out.println(redistemplate.opsforvalue().get( "key1" ));

     //redis中直接查看时，正常

     stringredistemplate.opsforvalue().set( "key2" , "hello2" );

     system.out.println(stringredistemplate.opsforvalue().get( "key2" ));

     redisconnection connection = redistemplate.getconnectionfactory().getconnection();

     connection.set( "key3" .getbytes(), "hello3" .getbytes());

     system.out.println( new string(connection.get( "key3" .getbytes())));

     hashoperations<string, object, object> hash = stringredistemplate.opsforhash();

     hash.put( "key4" , "name" , "张三" );

     hash.put( "key4" , "age" , "18" );

     system.out.println(hash.get( "key4" , "name" ));

     system.out.println(hash.entries( "key4" ));

     stringredistemplate.sethashvalueserializer( new jackson2jsonredisserializer<object>(object. class ));

     jackson2hashmapper jackson2hashmapper = new jackson2hashmapper(objectmapper, false ); // true 扁平化（将对象中的参数展开）

     user user = new user();

     user.setid( 123 );

     user.setname( "zhangsan" );

     stringredistemplate.opsforhash().putall( "key5" , jackson2hashmapper.tohash(user));

     map map = stringredistemplate.opsforhash().entries( "key5" );

     user user1 = objectmapper.convertvalue(map, user. class );

     system.out.println(user1.getid());

     system.out.println(user1.getname());

     mystringredistemplate.opsforhash().putall( "key6" , jackson2hashmapper.tohash(user));

     map map1 = mystringredistemplate.opsforhash().entries( "key6" );

     user user2 = objectmapper.convertvalue(map, user. class );

     system.out.println(user2.getid());

     system.out.println(user2.getname());

     //发布订阅

     mystringredistemplate.convertandsend( "qunliao" , "hello" );

     redisconnection connection1 = mystringredistemplate.getconnectionfactory().getconnection();

     connection1.subscribe( new messagelistener() {

       @override

       public void onmessage(message message, byte [] bytes) {

         byte [] body = message.getbody();

         system.out.println( new string(body));

       }

     }, "qunliao" .getbytes());

     while ( true ){

       mystringredistemplate.convertandsend( "qunliao" , "hello" );

       try {

         thread.sleep( 3000 );

       } catch (interruptedexception e) {

         e.printstacktrace();

       }

     }

   }

}

package com.myspringboot.redis;

public class user {

   private int id;

   private string name;

   public int getid() {

     return id;

   }

   public void setid( int id) {

     this .id = id;

   }

   public string getname() {

     return name;

   }

   public void setname(string name) {

     this .name = name;

   }

}