Spring-redisはメッセージ生産者の発表と消費者の購読を実現する

4809 ワード

実行可能なredisのdemoがすでに存在し、コアredisプロファイルに直接アクセスしていることを前提としています.


  ：
import java.io.Serializable;
 
import org.springframework.data.redis.core.RedisTemplate;
 
import com.hthl.xxtd.model.email.EmailRecord;
 
/**
 *
 * @see    
 * @date
 * @version  
 * @desc         
 */
public class RedisService {
     
    private RedisTemplate redisTemplate;
     
    /**
     *    ：    
     * */
    public void sendEmail(EmailRecord emailRecord){
        redisTemplate.convertAndSend("hthl_email",emailRecord);
    }
} ：
import javax.annotation.Resource;
 
import org.apache.log4j.Logger;
 
import com.hthl.xxtd.model.email.EmailRecord;
import com.hthl.xxtd.service.email.EmailChannelService;
 
import net.sf.json.JSONObject;
/**
 *    
 * */
public class RedisMessageListenerContainer{
    private static final Logger logger = Logger.getLogger(RedisMessageListenerContainer.class);
    @Resource
    private EmailChannelService emailChannelService;
 
    //    
    public void sendEmail(EmailRecord  emailRecord, String channel) {
	//do something
        logger.info("   "+channel+"    :"+ JSONObject.fromObject(emailRecord).toString());
    }
 
} ： ，， channel

Keystonejsの最初の観察

ビッグデータを開始する最初のステップ:データ分析者コース<2週目の学習ログ>