jedis的使用，spring整合redis，springboot整合redis

标签：区别   wired   val   取消   自定义   isa   cto   转换   idle   

1. java使用redis

很简单，看我的github的例子就行

1. spirng整合redis，这里用xml配置方式实现

2.1导包

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


  redis.clients
  jedis
  2.1.0

2.2配置applicationContext.xml

Spring提供了很多序列化器

Jackson2JsonRedisSerializer

JdkSerializationRedisSerializer

OxmSerializer

StringRedisSerializer

GenericToStringRedisSerializer

GenericJackson2JsonRedisSerializer

2.3测试

ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
        "applicationContext.xml");
RedisTemplate redisTemplate = applicationContext
        .getBean(RedisTemplate.class);

2.4   StringRedisTemplete和RedisTemplete的区别

StringRedisTemplete继承RedisTemplete，内部使用string序列化器，所以适合操作key和value都是string的数据

3 Spring中发布订阅

3.1首先提供接收消息的类，它将实现 org.springframework.data.redis.connection.MessageListener 接口，并实现接口定义的方法 public void onMessage（Message message,byte[]pattern）

/*** imports ***/

1. public class RedisMessageListener implements MessageListener {
2.     private RedisTemplate redisTemplate;
3.  
4.     /*** 此处省略redisTemplate的 setter和getter方法 ***/
5.     @Override
6.     public void onMessage(Message message, byte[] bytes) {
7.         // 获取消息
8.         byte[] body = message.getBody();
9.         // 使用值序列化器转换
10. 10.         String msgBody = (String) getRedisTemplate().getValueSerializer()
11. 11.                 .deserialize(body);
12. 12.         System.err.println(msgBody);
13. 13.         // 获取 channel
14. 14.         byte[] channel = message.getChannel();
15. 15.         // 使用字符串序列化器转换
16. 16.         String channelStr = (String) getRedisTemplate().getStringSerializer()
17. 17.                 .deserialize(channel);
18. 18.         System.err.println(channelStr);
19. 19.         // 渠道名称转换
20. 20.         String bytesStr = new String(bytes);
21. 21.         System.err.println(bytesStr);
22. 22.     }

23. }

3.2.在spring中配置自定义的监听器

   
   

3.3 要给一个监听容器，在 Spring 中已有类 org.springframework.data.redis.listener.RedisMessageListenerContainer。它可以用于监听 Redis 的发布订阅消息，下面的配置就是为了实现这个功能，读者可以通过注释来了解它的配置要点。

        class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
   



   

3.4 测试，像chat通道发送消息

1. ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
2. RedisTemplate redisTemplate = applicationContext.getBean(RedisTemplate.class);
3. String channel = "chat";
4. redisTemplate.convertAndSend(channel, "I am lazy!!");

4 springboot整合redis

4.1新建springboot项目，勾选上redis

 4.2配置application.yml

        spring:

  redis:

    host: 127.0.0.1

    port: 6379

    jedis:

      pool:

        max-active: 100

        max-idle: 10

        max-wait: 20000

    lettuce:

      shutdown-timeout: 1000

4.2 配置redis的配置类

@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){
        RedisTemplate redisTemplate = new RedisTemplate();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        redisTemplate.setKeySerializer(stringRedisSerializer());
        redisTemplate.setValueSerializer(jdkSerializationRedisSerializer());
        return redisTemplate;
    }
   
    @Bean
    public StringRedisSerializer stringRedisSerializer(){
        return new StringRedisSerializer();
    }
    @Bean
    public JdkSerializationRedisSerializer jdkSerializationRedisSerializer(){
        return new JdkSerializationRedisSerializer();
    }
}

4.3 测试

@SpringBootTest
class SpringbootRedisApplicationTests {
@Autowired
private RedisTemplate redisTemplate;
    @Test
    void contextLoads() {
        redisTemplate.opsForValue().set("myname","zhouyang");
        String myname = (String)redisTemplate.opsForValue().get("myname");
        System.out.println(myname);
    }

}

4.4 配置订阅发布

 4.4.1新建类实现MessageListener

        public class MyRedisMessageListener implements MessageListener {

    @Autowired

    private RedisTemplate redisTemplate;

    @Override

    public void onMessage(Message message, byte[] bytes) {

        // 获取消息

               byte[] body = message.getBody();

               // 使用值序列化器转换

                   String msgBody = (String) redisTemplate.getValueSerializer()

                           .deserialize(body);

                System.err.println(msgBody);

                   // 获取 channel

                   byte[] channel = message.getChannel();

                   // 使用字符串序列化器转换

               String channelStr = (String) redisTemplate.getStringSerializer()

                           .deserialize(channel);

                System.err.println(channelStr);

                // 渠道名称转换

               String bytesStr = new String(bytes);

               System.err.println(bytesStr);


    }

}

4.4.2 配置redisConfig，把messageListener和containner放入容器中

@Bean
public MyRedisMessageListener myRedisMessageListener(){
    return new MyRedisMessageListener();
}
@Bean
public RedisMessageListenerContainer  redisMessageListenerContainer (RedisConnectionFactory redisConnectionFactory){
    RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
    redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
    redisMessageListenerContainer.addMessageListener(myRedisMessageListener(),new PatternTopic("chat"));
    return redisMessageListenerContainer;
}

4.4.3测试

@Test
void testPublish() {
    redisTemplate.convertAndSend("chat","我是周扬");
}

jedis的使用，spring整合redis，springboot整合redis

标签：区别   wired   val   取消   自定义   isa   cto   转换   idle   

原文地址：https://www.cnblogs.com/zhouyanger/p/13215534.html