spring-data-redis 可以实现消息队列吗

发布网友 发布时间：2022-04-26 21:36

我来回答

共1个回答

热心网友 时间：2022-05-03 17:08

pom.xml添加配置
添加版本配置

2.8.1
1.7.2.RELEASE
2.2

redis.clients
jedis
${jedis.version}

org.apache.commons
commons-pool2
${commons-pool2.version}

org.springframework.data
spring-data-redis
${spring-data-redis.version}

properties文件添加配置
#redis配置
redis.host=192.168.1.150
redis.port=6379
redis.password=redis
redis.timeout=2000
redis.max_total=100
redis.max_idle=20
redis.min_idle=5
redis.test_on_borrow=true
redis.test_on_return=true

applicationContext.xml添加配置：

定义消息发送者（产者）：
@Component
public class SendMessage {

@Autowired
private RedisTemplate redisTemplate;

public void sendMessage(String channel, Serializable message) {
redisTemplate.convertAndSend(channel, message);
}
}

定义消息处理者（消费者）：
public class ListenMessage {
public void handleMessage(Serializable message){
System.out.println(message);
}
}

调用：/queue/redis
@Controller
@RequestMapping(value = "/queue")
public class QueueController {

@Autowired
SendMessage sendMessage;

@RequestMapping(value="/redis")
public void redis(){
for (int i = 0; i <1000; i++) {
sendMessage.sendMessage("java",i);
}
}
}