| | |
| | | import java.util.*;
|
| | | import java.util.concurrent.TimeUnit;
|
| | |
|
| | | import com.alibaba.fastjson.JSONObject;
|
| | | import org.springframework.beans.factory.annotation.Autowired;
|
| | | import org.springframework.data.redis.core.*;
|
| | | import org.springframework.stereotype.Component;
|
| | |
| | | }
|
| | |
|
| | | // ============================== 消息发送与订阅 ==============================
|
| | | public void convertAndSend(String channel, String msg) {
|
| | | public void convertAndSend(String channel, JSONObject msg) {
|
| | | // redisTemplate.convertAndSend(channel, msg);
|
| | | redisTemplate.convertAndSend(channel, msg);
|
| | |
|
| | | }
|