这是我的reload类
@RedisHash("Reload")
public class Reload implements Serializable {
@Indexed
private Integer id;
@Indexed
private String email;
private String word;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getEmail() {
return email;
}
@Override
public String toString() {
return "Reload{" +
"id=" + id +
", email='" + email + '\'' +
", word='" + word + '\'' +
'}';
}
public void setEmail(String email) {
this.email = email;
}
public String getWord() {
return word;
}
public void setWord(String word) {
this.word = word;
}
}
这是我的测试类
@Test
public void addReload(){
String key="hash2";
Map<Integer,Reload> map=new HashMap<Integer, Reload>();
List<info> infoList=infodao.findInfo();
for(info info:infoList){
Reload reload=new Reload();
reload.setWord(info.getWord());
reload.setId(info.getId());
reload.setEmail(info.getEmail());
reload.setId(info.getId());
map.put(info.getId(),reload);
System.out.println(info);
}
这是我的Redis的数据
@RequestMapping("check")
public String forward(Reload reload, Model model){
String key="hash2";
Integer id=reload.getId();
String word=reload.getWord();
String email=reload.getEmail();
String m=id.toString();
uid=id;
//Redis的数据的scan操作
Cursor<Map.Entry<Integer, HashMap<Integer,Reload>>> cursor =redisTemplate.opsForHash().scan(key, ScanOptions.scanOptions().match(m).build());
//TreeMap<String,byte[]> streaming = new TreeMap<>();
HashMap<Integer,Reload> reloadHashMap=new HashMap<>();
//
Map.Entry<Integer, HashMap<Integer,Reload>> entry = cursor.next();
reloadHashMap=entry.getValue();
//Integer key2= entry.getKey();
System.out.println(reloadHashMap);
reloadHashMap.values();
Object[] value = new Reload[10];
value= reloadHashMap.values().toArray();
ObjectMapper objectMapper=new ObjectMapper();
Reload reload1=objectMapper.convertValue(value[0],Reload.class);
if(word.equals(reload1.getWord())){
model.addAttribute("list",reload.getId());
return "success";
}
else{
return "Execption";
}
}