spring集成redis实现聊天室功能

package com.redis.chat.controller; import com.redis.chat.model.ChatSubscribeModel; import com.redis.chat.redis.JedisClientSingle; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import javax.annotation.PostConstruct; import java.util.List; @Controller public class IndexController { @Autowired private JedisClientSingle jedisClientSingle; @RequestMapping(value = "") public String index() { return "index"; } @PostConstruct public void action() { //启动一个线程去获取数据 new Thread(new Runnable() { public void run() { try { String room = "lsy"; ChatSubscribeModel subscribe = new ChatSubscribeModel(); jedisClientSingle.subscribe(subscribe, room); } catch (Exception e) { e.printStackTrace(); } } }).start(); } @RequestMapping(value = "/sendmessage") public void sendmessage(String message) { //这里使用spring整合的jedisPool，使用一会就不能使用了。 //先这样写吧 JedisPool jedisPool = new JedisPool("127.0.0.1",6379); Jedis jedis = jedisPool.getResource(); jedis.publish("lsy",message); jedis.close(); jedisPool.close(); } @RequestMapping(value = "/receiveMessage") @ResponseBody public List<String> receiveMessage() { return ChatSubscribeModel.messagelist; } }