import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericToStringSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
/**
* 生成redis测试数据
*/
@Component
@RequestMapping("/fwltj2")
public class Test2 {
@Resource
private RedisTemplate redisTemplate;
@Resource
private FwltjService fwltjService;
@Resource
private FwhmdService fwhmdService;
private Logger logger = LoggerFactory.getLogger(MyJob.class);
Integer a = 0;
private RedisTemplate<String, String> ObjectRedisTemplate;
/**
* redis实例化
*
* @return
*/
private RedisTemplate<String, String> getObjectRedisTemplate() {
if (ObjectRedisTemplate == null) {
ObjectRedisTemplate = Template();
}
return ObjectRedisTemplate;
}
private RedisTemplate<String, String> Template() {
// RedisTemplate<Object, Object> template = new RedisTemplate<>();
RedisTemplate<String, String> template = new RedisTemplate<String, String>();
template.setKeySerializer(new StringRedisSerializer());
template.setValueSerializer(new GenericToStringSerializer<String>(String.class));
template.setExposeConnection(true);
template.setConnectionFactory(redisTemplate.getConnectionFactory());
template.afterPropertiesSet();
return template;
}
@RequestMapping("/test3.do")
public void blacklist(Fwhmd fwhmd) {
int a = 0;
for (int i = 0; i < 100; i++) {
a++;
String ip = "192.192.168.";
String IP = ip + a;
fwhmd.setIp(IP);
fwhmdService.addFwhmd(fwhmd);
}
}
@RequestMapping("/test5.do")
public void test5() {
RedisTemplate<String, String> objectRedisTemplate = getObjectRedisTemplate();
//黑名单数据库存入redis
List<Fwhmd> fwhmd = fwhmdService.findFwhmd();
List<String> list1 = new ArrayList<String>();
for (Fwhmd fwhmd2 : fwhmd) {
String ip = fwhmd2.getIp();
list1.add(ip);
}
objectRedisTemplate.opsForList().leftPush(WebConstant.IP_HMD_KEY, String.valueOf(list1));
System.out.println("list1------>>>>" + list1.toString());
}
@RequestMapping("/test6.do")
public void test6() {
RedisTemplate<String, String> objectRedisTemplate = getObjectRedisTemplate();
//读取 redis
List<String> resultList1 = objectRedisTemplate.opsForList().range(WebConstant.IP_HMD_KEY, 0, -1);
for (String s : resultList1) {
System.out.println("resultList1------> " + s);
}
}
}
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/192860.html
