SpringBoot統合Redisメッセージ配信サブスクリプション

public class RedisConstant {
    /**
   	 *         
   	 */
   	public static final String TOPIC_PRAISE = "TOPIC_PRAISE";
   	/**
   	 *         
   	 */
   	public static final String TOPIC_COLLECT = "TOPIC_COLLECT";
   	/**
   	 *         
   	 */
   	public static final String TOPIC_COMMENT = "TOPIC_COMMENT";
   	/**
   	 *         
   	 */
   	public static final String TOPIC_FOCUS = "TOPIC_FOCUS";
}

package com.java.single.service.impl;
import java.util.concurrent.CountDownLatch;
import com.java.single.entity.res.MessageCollect;
import com.java.single.entity.res.MessageComment;
import com.java.single.entity.res.MessageFocus;
import com.java.single.util.PushUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Service
public class ReceiverServiceImpl {

	private CountDownLatch latch;

	@Autowired
	public ReceiverServiceImpl(CountDownLatch latch) {
		this.latch = latch;
	}

	public void praiseReceive(MessagePraise messagePraise) {
		log.info("      :[{}]", messagePraise);
		PushUtil.pushOne(messagePraise.getToUserId(), "   ",
				messagePraise.getUserName() + "    " + messagePraise.getTitle() + "   ");
		latch.countDown();
	}

	public void collectReceive(MessageCollect messageCollect) {
		log.info("      :[{}]", messageCollect);
		PushUtil.pushOne(messageCollect.getToUserId(), "   ",
				messageCollect.getUserName() + "     " + messageCollect.getTitle() + "   ");
		latch.countDown();
	}

	public void commentReceive(MessageComment messageComment) {
		log.info("      :[{}]", messageComment);
		PushUtil.pushOne(messageComment.getToUserId(), "      ",
				messageComment.getUserName() + " " + messageComment.getTitle() + "     :" + messageComment.getText());
		latch.countDown();
	}

	public void focusReceive(MessageFocus messageFocus) {
		log.info("      :[{}]", messageFocus);
		PushUtil.pushOne(messageFocus.getToUserId(), "   ", messageFocus.getUserName() + "    ");
		latch.countDown();
	}
}

 package com.java.single.entity.res;
 import java.io.Serializable;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
 @Data
 @NoArgsConstructor
 public class MessageCollect implements Serializable {
 	/**
 	 * 
 	 */
 	private static final long serialVersionUID = 1L;
 	/**
 	 *       
 	 */
 	private String id;
 	/**
 	 *       
 	 */
 	private String userId;
 	/**
 	 *       
 	 */
 	private String userName;
 	/**
 	 *       
 	 */
 	private String title;
 	/**
 	 *       
 	 */
 	private String toUserId;
 	/**
 	 * 
 	 * @param id
 	 *                  
 	 * @param userId
 	 *                  
 	 * @param userName
 	 *                  
 	 * @param title
 	 *                  
 	 * @param toUserId
 	 *                  
 	 */
 	public MessageCollect(String id, String userId, String userName, String title, String toUserId) {
 		super();
 		this.id = id;
 		this.userId = userId;
 		this.userName = userName;
 		this.title = title;
 		this.toUserId = toUserId;
 	}
}

import java.util.concurrent.CountDownLatch;
import com.java.single.constant.RedisConstant;
import com.java.single.service.impl.ReceiverServiceImpl;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;

@Configuration
public class RedisMessageListener {

	/**
	 * redis       
	 * 
	 * @param connectionFactory
	 * @param praiseListenerAdapter
	 *                     
	 * @param collectListenerAdapter
	 *                     
	 * @param commentListenerAdapter
	 *                     
	 * @param focusListenerAdapter
	 *                     
	 * @return
	 */
	@Bean
	RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
			MessageListenerAdapter praiseListenerAdapter, MessageListenerAdapter collectListenerAdapter,
			MessageListenerAdapter commentListenerAdapter, MessageListenerAdapter focusListenerAdapter) {
		RedisMessageListenerContainer container = new RedisMessageListenerContainer();
		container.setConnectionFactory(connectionFactory);
		
		//              ，             String  ,             String  
		Jackson2JsonRedisSerializer

redisTemplate.convertAndSend(RedisConstant.TOPIC_COLLECT,
					new MessageCollect(id, userPublish.getUserId(), userName, title, userId));