mongodbmysqlh2redis
- gradle
compile('org.springframework.boot:spring-boot-starter-data-mongodb')
testCompile('de.flapdoodle.embed:de.flapdoodle.embed.mongo')
- entity
@Document(collection = "contact")
@Getter
@Builder(toBuilder = true)
@NoArgsConstructor
@AllArgsConstructor
@ToString
public class ContactPerson {
@JsonFormat(shape = JsonFormat.Shape.STRING)
private Long id;
private String contactPerson;
private String contactPhone;
}
- Mongo Respository
@RepositoryRestResource(collectionResourceRel = "contact", path = "contact", exported = true)
public interface ContactPersonRepository extends MongoRepository<ContactPerson, Long> {
public ContactPerson save(ContactPerson contactPerson);
public List<ContactPerson> findByContactPersonLike(@Param("contactPerson") String contactPerson);
}
- controller
@PostMapping("/mongo")
public ResponseEntity<?> saveContactPerson(@RequestBody ContactPerson contactPerson) {
return ResponseEntity.ok(contactPersonRepository.save(contactPerson));
}
@GetMapping("/mongo/{name}")
public ResponseEntity<?> getContactPerson(@PathVariable String name) {
return ResponseEntity.ok(contactPersonRepository.findByContactPersonLike(name));
}
- controller test
@Test
public void testFindConstactPersonByName() throws Exception {
ContactPerson contactPerson =
ContactPerson.builder()
.id(100L)
.contactPerson("ceshi1")
.contactPhone("13500110022")
.address("北京市朝阳区")
.remark("ceshi")
.build();
mongoTemplate.insert(contactPerson);
mockMvc
.perform(get("/v1/api/mmr/mongo/{name}", "ceshi"))
.andExpect(status().isOk())
.andExpect(jsonPath("$", hasSize(1)))
.andExpect(jsonPath("$.[0].contactPerson").value("ceshi1"));
}
- gradle
compile('org.springframework.boot:spring-boot-starter-amqp')
testCompile('org.apache.qpid:qpid-broker:6.1.2')
-
config
- 测试目录下模拟启动amqp
- 申明mq的exchange 和 queue
-
rabbit mq listener
监听队列，接收消息
@RabbitListener(queues = AmqpConfig.RECEIPT_VOUCHER_QUEUE)
public void receive(String message) throws IOException {
System.out.println("接受消息内容:" + message);
messageDatas.add(objectMapper.readValue(message, ContactPerson.class));
}- integration test 发送消息到测试队列，并检查消费是否成功
- gradle
compile(
'org.springframework.data:spring-data-redis',
'redis.clients:jedis'
)
testCompile(
'com.github.kstyrc:embedded-redis:0.6'
)
- mock redis connection
@Configuration
@Profile("integTest")
public class RedisConfig {
private RedisServer redisServer;
@Value("localhost")
private String redisHost;
@Value("${random.int[58000,60000]}")
private int redisPort;
@Bean
@Primary
JedisConnectionFactory jedisConnectionFactory() {
JedisConnectionFactory factory = new JedisConnectionFactory(
new RedisStandaloneConfiguration(redisHost, redisPort)
);
return factory;
}
@PostConstruct
public void startRedis() throws IOException {
redisServer = new RedisServer(redisPort);
redisServer.start();
}
@PreDestroy
public void stopRedis() {
redisServer.stop();
}
}-
cache configuration
定义自己的cachemanage 和cache 名称，还有redis存储序列化的相关配置
-
cache service
增加缓存的操作方法，注意使用如下注解
@Cacheable@CachePut@CacheEvict -
启用缓存
启动类增加注解
@EnableCaching