springboot学习笔记-3 整合redis&mongodb

àì夳堔傛蜴生んèń 2021-12-21 03:51 247阅读 0赞

**一.整合redis**

**1.1 建立实体类**

![复制代码][copycode.gif]

@Entity
    @Table(name="user")
    public class User implements Serializable {
        @Id
        @GeneratedValue(strategy=GenerationType.AUTO)
        private Long id;
        private String name;
        @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
        private Date createDate;
        
        @JsonBackReference        //防止json的重复引用问题
        private Department department;
        private Set<Role> roles;
        public Long getId() {
            return id;
        }
        public void setId(Long id) {
            this.id = id;
        }
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
        public Date getCreateDate() {
            return createDate;
        }
        public void setCreateDate(Date createDate) {
            this.createDate = createDate;
        }
        public Department getDepartment() {
            return department;
        }
        public void setDepartment(Department department) {
            this.department = department;
        }
        public Set<Role> getRoles() {
            return roles;
        }
        public void setRoles(Set<Role> roles) {
            this.roles = roles;
        }
        @Override
        public String toString() {
            return "User [id=" + id + ", name=" + name + ", createDate=" + createDate + ", department=" + department
                    + ", roles=" + roles + "]";
        }
        
    }

![复制代码][copycode.gif]

**1.2 建立Redis的配置类**

**　**　首先导入pom.xml相应的依赖

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-redis</artifactId>
    </dependency>

在springboot中,没有去提供直接操作Redis的Repository,但是我们可以使用RedisTemplate去访问Redis.想要去使用RedisTemplate,首先需要完成一些必要的配置.这里使用配置类去完成.

在application.properties中建立Redis的相关配置:

![972319-20170124185434331-919590642.png][]

建立配置类,配置RedisTemplate,而要使用RedisTemplate还需要配置RedisConnectionFactory:

![复制代码][copycode.gif]

@ConfigurationProperties("application.properties")
    @Configuration
    public class RedisConfig {
        @Value("${spring.redis.hostName}")
        private String hostName;
        @Value("${spring.redis.port}")
        private Integer port;
    
        @Bean
        public RedisConnectionFactory redisConnectionFactory() {
            JedisConnectionFactory cf = new JedisConnectionFactory();  
            cf.setHostName(hostName);  
            cf.setPort(port); 
            cf.afterPropertiesSet();  
            return cf;  
        }
        
        @Bean
        public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
            StringRedisTemplate template=new StringRedisTemplate(factory);
            Jackson2JsonRedisSerializer jackson2JsonRedisSerializer=new Jackson2JsonRedisSerializer(Object.class);
            ObjectMapper om=new ObjectMapper();
            om.setVisibility(PropertyAccessor.ALL,JsonAutoDetect.Visibility.ANY);
            om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jackson2JsonRedisSerializer.setObjectMapper(om);
            template.setValueSerializer(jackson2JsonRedisSerializer);
            template.afterPropertiesSet();
            return template;
        }
    }

![复制代码][copycode.gif]

**1.3 建立UserRedis类,它实现了与Redis的交互**

注意,在UserRedis中,使用了Redis的数据结构中最常用的key-value都是字符串的形式,采用Gson将对象转化为字符串然后存放到redis中.

![复制代码][copycode.gif]

@Repository
    public class UserRedis {
        @Autowired
        private RedisTemplate<String, String> redisTemplate;
        
        public void add(String key,User user) {
            Gson gson=new Gson();
            redisTemplate.opsForValue().set(key,gson.toJson(user));
        }
        public void add(String key,List<User> users) {
            Gson gson=new Gson();
            redisTemplate.opsForValue().set(key,gson.toJson(users));
        }
        public User get(String key ) {
            Gson gson=new Gson();
            User user=null;
            String userStr=redisTemplate.opsForValue().get(key);
            if(!StringUtils.isEmpty(userStr))
                user=gson.fromJson(userStr, User.class);
            return user;
        }
        public List<User> getList(String key) {
            Gson gson=new Gson();
            List<User> users=null;
            String listJson=redisTemplate.opsForValue().get(key);
            if(!StringUtils.isEmpty(listJson)) {
                users=gson.fromJson(listJson,new TypeToken<List<User>>(){}.getType());
            }
            return users;
        }
        public void delete(String key) {
            redisTemplate.opsForValue().getOperations().delete(key);
        }
    }

![复制代码][copycode.gif]

**1.4 建立UserController类**

它自动注入了UserRedis类,通过不同的url实现了向redis存储数据,获取数据的功能.

![复制代码][copycode.gif]

@Controller
    public class UserController {
        @Autowired
        UserRedis userRedis;
        
        @RequestMapping("/user/testRedisSave")
        public String testRedis() {
            Department department=new Department();
            department.setName("开发部");
            Role role=new Role();
            role.setName("admin");
            User user=new User();
            user.setName("hlhdidi");
            user.setCreateDate(new Date());
            user.setDepartment(department);
            Set<Role> roles=new HashSet<>();
            roles.add(role);
            user.setRoles(roles);
            userRedis.delete(this.getClass().getName()+":username:"+user.getName());
            userRedis.add(this.getClass().getName()+":username:"+user.getName(), user);
            return null;
        }
        @RequestMapping("/user/testRedisGet")
        public String testRedis2() {
            User user=userRedis.get(this.getClass().getName()+":username:hlhdidi");
            System.out.println(user);
            return null;
        }
    }

![复制代码][copycode.gif]

先访问localhost:8080/user/testRedisSave,再访问localhost:8080/user/testRedisGet,即可测试成功!

二.整合MongoDB

MongoDB是一种文档类型的NoSql数据库.它内部有三个层次的概念,分别为数据库,集合,文档.使用springboot可以非常方便的整合MongoDB

**2.1 建立mongo.properties配置文件**

![972319-20170124191122269-449177932.png][]

导入依赖:

![复制代码][copycode.gif]

<dependency>
                <groupId>org.pegdown</groupId>
                <artifactId>pegdown</artifactId>
                <version>1.4.1</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-hateoas</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.data</groupId>
                <artifactId>spring-data-mongodb</artifactId>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-annotations</artifactId>
            </dependency>

![复制代码][copycode.gif]

**2.2 建立MongoConfig配置类,完成对于MongoDB的配置**

![复制代码][copycode.gif]

@Configuration
    @EnableMongoRepositories(basePackages={"com.hlhdidi.springboot.mongo"})//MongoRepository的扫描包
    @PropertySource("classpath:mongo.properties")//注入配置文件属性
    public class MongoConfig extends AbstractMongoConfiguration{
    
        @Autowired
        private Environment env;
        
        @Override
        protected String getDatabaseName() {
            return env.getRequiredProperty("mongo.name");
        }
    
        @Override
        @Bean
        public Mongo mongo() throws Exception {
            ServerAddress serverAddress=new ServerAddress(env.getRequiredProperty("mongo.host"));
            List<MongoCredential> credentials=new ArrayList<>();
            return new MongoClient(serverAddress, credentials);
        }
    
    }

![复制代码][copycode.gif]

**2.3 建立SysUser实体类.**

该实体类需要被存储到MongoDB数据库中.

![复制代码][copycode.gif]

@Document(collection="user")//配置collection的名称,如果没有将会自动建立对应的Collection
    public class SysUser {
        @Id
        private String userId;
        @NotNull @Indexed(unique=true)
        private String username;
        @NotNull
        private String password;
        @NotNull
        private String name;
        @NotNull
        private String email;
        @NotNull
        private Date registrationDate=new Date();
        private Set<String> roles=new HashSet<>();
        public SysUser(){}
        @PersistenceConstructor
        public SysUser(String userId, String username, String password, String name, String email, Date registrationDate,
                Set<String> roles) {
            super();
            this.userId = userId;
            this.username = username;
            this.password = password;
            this.name = name;
            this.email = email;
            this.registrationDate = registrationDate;
            this.roles = roles;
        }
        public String getUserId() {
            return userId;
        }
        public void setUserId(String userId) {
            this.userId = userId;
        }
        public String getUsername() {
            return username;
        }
        public void setUsername(String username) {
            this.username = username;
        }
        public String getPassword() {
            return password;
        }
        public void setPassword(String password) {
            this.password = password;
        }
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
        public String getEmail() {
            return email;
        }
        public void setEmail(String email) {
            this.email = email;
        }
        public Date getRegistrationDate() {
            return registrationDate;
        }
        public void setRegistrationDate(Date registrationDate) {
            this.registrationDate = registrationDate;
        }
        public Set<String> getRoles() {
            return roles;
        }
        public void setRoles(Set<String> roles) {
            this.roles = roles;
        }
        @Override
        public String toString() {
            return "SysUser [userId=" + userId + ", username=" + username + ", password=" + password + ", name=" + name
                    + ", email=" + email + ", registrationDate=" + registrationDate + ", roles=" + roles + "]";
        }
        
    }

![复制代码][copycode.gif]

**2.4 建立SysUserRepository**

由于springboot已经帮我们提供了操作MongoDB数据库的API,因此直接继承对应的类即可(和JPA一致)

@Repository
    public interface SysUserRepository extends MongoRepository<SysUser, String>{
    
    }

**2.5 测试**

测试类先向MongoDB中存储了一个实体类对象,随后获取指定对象的指定Collections下面的所有文档

![复制代码][copycode.gif]

@RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(classes={MongoConfig.class})
    @FixMethodOrder
    public class MongoTest {
        @Autowired
        SysUserRepository repository;
        
        @Before
        public void setup() {
            Set<String> roles=new HashSet<>();
            roles.add("manage");
            SysUser sysUser=new SysUser("1", "hlhdidi", "123", "xiaohulong", "email@com.cn", new Date(), roles);
            repository.save(sysUser);
        }
        @Test
        public void findAll() {
            List<SysUser> users=repository.findAll();
            for(SysUser user:users) {
                System.out.println(user);
            }
        }
    }

![复制代码][copycode.gif]

转自：[https://www.cnblogs.com/hlhdidi/p/6347719.html][https_www.cnblogs.com_hlhdidi_p_6347719.html]

[copycode.gif]: /images/20211221/9743afa68c2c45409d20f92cdc71e4ba.png
[972319-20170124185434331-919590642.png]: /images/20211221/88e31296c6e04d7289ad1f4f9daf606a.png
[972319-20170124191122269-449177932.png]: /images/20211221/953241aaeb414d6c81fb4e42ce03dea3.png
[https_www.cnblogs.com_hlhdidi_p_6347719.html]: https://www.cnblogs.com/hlhdidi/p/6347719.html