配置文件：

消息处理类：

public class DefaultMessageDelegate {    @Autowired    private TrademarkMatchService trademarkMatchService;    public void handleMessage(String message) {        try {            String[] ids = message.split("::");            System.out.println(ids);            String trademarkId = ids[0];            String openid = ids[1];            trademarkMatchService.vote(Long.parseLong(trademarkId), openid);        } catch (Exception e) {            e.printStackTrace();        }    }}

发布消息：

@Autowiredprivate StringRedisTemplate redisTemplate;redisTemplate.convertAndSend("votes_message", "123345"+"::"+5522);

设置值：

redisTemplate.opsForValue().set("test", "testnew", 10, TimeUnit.SECONDS);

获取值：

String result = redisTemplate.opsForValue().get("votes_message");