消息队列
基于redis实现的消息队列
依赖
<dependency>
<groupId>com.ipet</groupId>
<artifactId>quick-queue-redis</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
环境
使用spring redis配置
spring.redis.password=wIvJt@_redis
spring.redis.database=1
spring.redis.sentinel.master=sharddev6389
spring.redis.sentinel.nodes=192.168.11.29:26002,192.168.11.32:26002,192.168.11.20:26002
#redis IO 10 ms 超时
spring.redis.timeout=1000
spring.redis.pool.max-active=-1
调用
生产者
//通过RedisQueueScanner注入消息队列接口
@RedisQueueScanner("com.ipet.test.queue")
@Configuration
@SpringBootApplication
public class ServiceExecutor {
public static void main(String[] args) throws InterruptedException {
new SpringApplication(ServiceExecutor.class).run(args);
new CountDownLatch(1).await();
}
}
//通过RedisQueue接口定义消息队列生产者interface
//通过RedisQueueProvider接口定义生产者队列名称
@RedisQueue
public interface TestQueue {
@RedisQueueProvider("queue1")
void sendMessage1(String msg);
@RedisQueueProvider("queue2")
void sendMessage2(List<String> msgList);
}
//消息发送
@Component
@EnableScheduling
public class QueueTask {
@Autowired
private TestQueue testQueue;
@Autowired
private TestQueue1 testQueue1;
@Scheduled(cron = "0/5 * * * * ?")
public void queue1Task(){
//定义好消息队列的接口可直接调用，不需要管实现，实现由代理完成
testQueue.sendMessage1("Msg:[" + (int)(Math.random() * Integer.MAX_VALUE) + "]");
}
@Scheduled(cron = "0/10 * * * * ?")
public void queue2Task(){
testQueue.sendMessage2(Arrays.asList("Hello ","World."));
}
@Scheduled(cron = "0/5 * * * * ?")
public void queue3Task(){
testQueue1.sendMessage1("Msg:[" + (int)(Math.random() * Integer.MAX_VALUE) + "]");
}
@Scheduled(cron = "0/10 * * * * ?")
public void queue4Task(){
testQueue1.sendMessage2(Arrays.asList("Hello ","World."));
}
}
消费者
//继承AbstractRedisQueueConsumer并通过RedisQueueConsumer注解标明队列名称即可
@RedisQueueConsumer("queue1")
public class Message1Consumer extends AbstractRedisQueueConsumer<String> {
private Logger logger = LoggerFactory.getLogger(getClass());
@Override
public void doConsume(String message) {
logger.info("Message1 : [{}]",message);
}
}
git地址：https://gitee.com/yangyale/quick-queue-redis
欢迎工作一到五年的Java工程师朋友们加入JavaQQ群：219571750，群内提供免费的Java架构学习资料（里面有高可用、高并发、高性能及分布式、Jvm性能调优、Spring源码，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多个知识点的架构资料）合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！
