org.springframework.data.redis.core.RedisTemplate.setEnableDefaultSerializer()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(12.5k)|赞(0)|评价(0)|浏览(88)

本文整理了Java中org.springframework.data.redis.core.RedisTemplate.setEnableDefaultSerializer方法的一些代码示例，展示了RedisTemplate.setEnableDefaultSerializer的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RedisTemplate.setEnableDefaultSerializer方法的具体详情如下：
包路径：org.springframework.data.redis.core.RedisTemplate
类名称：RedisTemplate
方法名：setEnableDefaultSerializer

RedisTemplate.setEnableDefaultSerializer介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-integration

public RedisPublishingMessageHandler(RedisConnectionFactory connectionFactory) {
  Assert.notNull(connectionFactory, "connectionFactory must not be null");
  this.template = new RedisTemplate<Object, Object>();
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.afterPropertiesSet();
}

代码示例来源：origin: spring-projects/spring-integration

public RedisQueueOutboundGateway(String queueName, RedisConnectionFactory connectionFactory) {
  Assert.hasText(queueName, "'queueName' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.setKeySerializer(new StringRedisSerializer());
  this.template.afterPropertiesSet();
  this.boundListOps = this.template.boundListOps(queueName);
}

代码示例来源：origin: spring-projects/spring-integration

public RedisQueueOutboundChannelAdapter(Expression queueNameExpression, RedisConnectionFactory connectionFactory) {
  Assert.notNull(queueNameExpression, "'queueNameExpression' is required");
  Assert.hasText(queueNameExpression.getExpressionString(), "'queueNameExpression.getExpressionString()' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  this.queueNameExpression = queueNameExpression;
  this.template = new RedisTemplate<String, Object>();
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.setKeySerializer(new StringRedisSerializer());
  this.template.afterPropertiesSet();
}

代码示例来源：origin: spring-projects/spring-integration

/**
 * @param queueName         Must not be an empty String
 * @param connectionFactory Must not be null
 */
public RedisQueueMessageDrivenEndpoint(String queueName, RedisConnectionFactory connectionFactory) {
  Assert.hasText(queueName, "'queueName' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  RedisTemplate<String, byte[]> template = new RedisTemplate<String, byte[]>();
  template.setConnectionFactory(connectionFactory);
  template.setEnableDefaultSerializer(false);
  template.setKeySerializer(new StringRedisSerializer());
  template.afterPropertiesSet();
  this.boundListOperations = template.boundListOps(queueName);
}

代码示例来源：origin: spring-projects/spring-integration

/**
 * @param queueName Must not be an empty String
 * @param connectionFactory Must not be null
 */
public RedisQueueInboundGateway(String queueName, RedisConnectionFactory connectionFactory) {
  Assert.hasText(queueName, "'queueName' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  this.template = new RedisTemplate<String, byte[]>();
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.setKeySerializer(new StringRedisSerializer());
  this.template.afterPropertiesSet();
  this.boundListOperations = this.template.boundListOps(queueName);
}

代码示例来源：origin: spring-projects/spring-integration

redisTemplate.setEnableDefaultSerializer(false);
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());

代码示例来源：origin: spring-projects/spring-integration

redisTemplate.setEnableDefaultSerializer(false);
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());

代码示例来源：origin: spring-projects/spring-integration

redisTemplate.setEnableDefaultSerializer(false);
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());

代码示例来源：origin: spring-projects/spring-integration

template.setEnableDefaultSerializer(false);
template.afterPropertiesSet();

代码示例来源：origin: spring-projects/spring-integration

redisTemplate.setEnableDefaultSerializer(false);
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());

代码示例来源：origin: spring-projects/spring-integration

redisTemplate.setEnableDefaultSerializer(false);
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());

代码示例来源：origin: org.springframework.integration/spring-integration-redis

public RedisPublishingMessageHandler(RedisConnectionFactory connectionFactory) {
  Assert.notNull(connectionFactory, "connectionFactory must not be null");
  this.template = new RedisTemplate<Object, Object>();
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.afterPropertiesSet();
}

代码示例来源：origin: org.springframework.integration/spring-integration-redis

public RedisQueueOutboundChannelAdapter(Expression queueNameExpression, RedisConnectionFactory connectionFactory) {
  Assert.notNull(queueNameExpression, "'queueNameExpression' is required");
  Assert.hasText(queueNameExpression.getExpressionString(), "'queueNameExpression.getExpressionString()' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  this.queueNameExpression = queueNameExpression;
  this.template = new RedisTemplate<String, Object>();
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.setKeySerializer(new StringRedisSerializer());
  this.template.afterPropertiesSet();
}

代码示例来源：origin: org.springframework.integration/spring-integration-redis

public RedisQueueOutboundGateway(String queueName, RedisConnectionFactory connectionFactory) {
  Assert.hasText(queueName, "'queueName' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.setKeySerializer(new StringRedisSerializer());
  this.template.afterPropertiesSet();
  this.boundListOps = this.template.boundListOps(queueName);
}

代码示例来源：origin: spring-projects/spring-integration

@Test
@RedisAvailable
public void testInt3015ExtractPayloadFalse() throws Exception {
  final String queueName = "si.test.testRedisQueueOutboundChannelAdapter2";
  final RedisQueueOutboundChannelAdapter handler = new RedisQueueOutboundChannelAdapter(queueName,
      this.connectionFactory);
  handler.setExtractPayload(false);
  Message<String> message = MessageBuilder.withPayload("testing").build();
  handler.handleMessage(message);
  RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
  redisTemplate.setConnectionFactory(this.connectionFactory);
  redisTemplate.setEnableDefaultSerializer(false);
  redisTemplate.setKeySerializer(new StringRedisSerializer());
  redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
  redisTemplate.afterPropertiesSet();
  Object result = redisTemplate.boundListOps(queueName).rightPop(5000, TimeUnit.MILLISECONDS);
  assertNotNull(result);
  assertEquals(message, result);
}

代码示例来源：origin: spring-projects/spring-integration

@Test
@RedisAvailable
public void testInt3015Default() throws Exception {
  final String queueName = "si.test.testRedisQueueOutboundChannelAdapter";
  final RedisQueueOutboundChannelAdapter handler = new RedisQueueOutboundChannelAdapter(queueName,
      this.connectionFactory);
  String payload = "testing";
  handler.handleMessage(MessageBuilder.withPayload(payload).build());
  RedisTemplate<String, ?> redisTemplate = new StringRedisTemplate();
  redisTemplate.setConnectionFactory(this.connectionFactory);
  redisTemplate.afterPropertiesSet();
  Object result = redisTemplate.boundListOps(queueName).rightPop(5000, TimeUnit.MILLISECONDS);
  assertNotNull(result);
  assertEquals(payload, result);
  Date payload2 = new Date();
  handler.handleMessage(MessageBuilder.withPayload(payload2).build());
  RedisTemplate<String, ?> redisTemplate2 = new RedisTemplate<String, Object>();
  redisTemplate2.setConnectionFactory(this.connectionFactory);
  redisTemplate2.setEnableDefaultSerializer(false);
  redisTemplate2.setKeySerializer(new StringRedisSerializer());
  redisTemplate2.setValueSerializer(new JdkSerializationRedisSerializer());
  redisTemplate2.afterPropertiesSet();
  Object result2 = redisTemplate2.boundListOps(queueName).rightPop(5000, TimeUnit.MILLISECONDS);
  assertNotNull(result2);
  assertEquals(payload2, result2);
}

代码示例来源：origin: org.springframework.integration/spring-integration-redis

/**
 * @param queueName         Must not be an empty String
 * @param connectionFactory Must not be null
 */
public RedisQueueMessageDrivenEndpoint(String queueName, RedisConnectionFactory connectionFactory) {
  Assert.hasText(queueName, "'queueName' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  RedisTemplate<String, byte[]> template = new RedisTemplate<String, byte[]>();
  template.setConnectionFactory(connectionFactory);
  template.setEnableDefaultSerializer(false);
  template.setKeySerializer(new StringRedisSerializer());
  template.afterPropertiesSet();
  this.boundListOperations = template.boundListOps(queueName);
}

代码示例来源：origin: org.springframework.integration/spring-integration-redis

/**
 * @param queueName Must not be an empty String
 * @param connectionFactory Must not be null
 */
public RedisQueueInboundGateway(String queueName, RedisConnectionFactory connectionFactory) {
  Assert.hasText(queueName, "'queueName' is required");
  Assert.notNull(connectionFactory, "'connectionFactory' must not be null");
  this.template = new RedisTemplate<String, byte[]>();
  this.template.setConnectionFactory(connectionFactory);
  this.template.setEnableDefaultSerializer(false);
  this.template.setKeySerializer(new StringRedisSerializer());
  this.template.afterPropertiesSet();
  this.boundListOperations = this.template.boundListOps(queueName);
}

代码示例来源：origin: spring-projects/spring-integration

@Test
@RedisAvailable
public void testInt3932LeftPushFalse() throws Exception {
  final String queueName = "si.test.Int3932LeftPushFalse";
  final RedisQueueOutboundChannelAdapter handler = new RedisQueueOutboundChannelAdapter(queueName,
      this.connectionFactory);
  handler.setLeftPush(false);
  String payload = "testing";
  handler.handleMessage(MessageBuilder.withPayload(payload).build());
  Date payload2 = new Date();
  handler.handleMessage(MessageBuilder.withPayload(payload2).build());
  RedisTemplate<String, ?> redisTemplate = new StringRedisTemplate();
  redisTemplate.setConnectionFactory(this.connectionFactory);
  redisTemplate.afterPropertiesSet();
  Object result = redisTemplate.boundListOps(queueName).leftPop(5000, TimeUnit.MILLISECONDS);
  assertNotNull(result);
  assertEquals(payload, result);
  RedisTemplate<String, ?> redisTemplate2 = new RedisTemplate<String, Object>();
  redisTemplate2.setConnectionFactory(this.connectionFactory);
  redisTemplate2.setEnableDefaultSerializer(false);
  redisTemplate2.setKeySerializer(new StringRedisSerializer());
  redisTemplate2.setValueSerializer(new JdkSerializationRedisSerializer());
  redisTemplate2.afterPropertiesSet();
  Object result2 = redisTemplate2.boundListOps(queueName).leftPop(5000, TimeUnit.MILLISECONDS);
  assertNotNull(result2);
  assertEquals(payload2, result2);
}

代码示例来源：origin: OracleChain/EosProxyServer

@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
  RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
  redisTemplate.setConnectionFactory(redisConnectionFactory);
  Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
  ObjectMapper objectMapper = new ObjectMapper();
  objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
  redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
  redisTemplate.setKeySerializer(new StringRedisSerializer());
  redisTemplate.setHashKeySerializer(jackson2JsonRedisSerializer);
  redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
  redisTemplate.setDefaultSerializer(jackson2JsonRedisSerializer);
  redisTemplate.setEnableDefaultSerializer(true);
  redisTemplate.afterPropertiesSet();
  return redisTemplate;
}

内容来源于网络，如有侵权，请联系作者删除！

redistemplate

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    RedisTemplate类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com