# spring-boot-test **Repository Path**: beifeng_spring_boot/spring-boot-test ## Basic Information - **Project Name**: spring-boot-test - **Description**: 整合的spring boot(hibernate)项目日常使用服务用例 - **Primary Language**: Java - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 1 - **Forks**: 0 - **Created**: 2017-07-31 - **Last Updated**: 2025-11-08 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README ##基于spring boot的使用用例 ---- `已支持如下服务` 1. 添加mq(rabbit mq ,kafka) 2. 数据源(数据库连接池使用阿里的druid) 3. 添加持久层(hibernate) 4. 添加缓存(ehcache,redis) 5. 添加mongodb支持 6. 添加任务调度,定时任务 7. 添加aop(基于注解) -----1 **下面是mq相关代码示例** ----- - 监听 ``` java import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component public class RabbitMQListener { @RabbitHandler @RabbitListener(queues = QueueConstant.QUEUE_HELLO) public void listen(String param) { System.out.printf("param=%s", param); } } ``` - 发送 ```java import javax.annotation.Resource; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.stereotype.Component; @Component public class RabbitMQSender { @Resource private AmqpTemplate amqpTemplate; public void send(String context) { amqpTemplate.convertAndSend(QueueConstant.QUEUE_HELLO, context); } } ``` - 队列 ```java import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RabbitQueueConfig { @Bean public Queue addHelloQueue() { return new Queue(QueueConstant.QUEUE_HELLO); } } ``` - 队列名 ```java public class QueueConstant { /**hello world 队列*/ public static final String QUEUE_HELLO = "hello.world"; } ```