Redis必知必会——发布订阅-创新互联

银行卡消费的时候，银行往往会通过微信、短信或邮件通知用户交易的详细信息，这便是发布订阅模式。
Redis必知必会——发布订阅
我们可以使用下面的命令进行模拟

创新互联为您提适合企业的网站设计让您的网站在搜索引擎具有高度排名，让您的网站具备超强的网络竞争力！结合企业自身，进行网站设计及把握，最后结合企业文化和具体宗旨等，才能创作出一份性化解决方案。从网站策划到成都网站制作、网站设计、外贸网站建设，我们的网页设计师为您提供的解决方案。

先打开一个客户端1，输入命令

SUBSCRIBE chat

表示客户端1订阅一个名为chat的渠道，之后打开客户端2,输入命令

publish chat "Hello World!"

Redis必知必会——发布订阅
在Spring中，我们自定义接收消息的类，需要实现MessageListener接口，并实现接口定义的方法onMessage，代码如下。

public class RedisMessageListener implements MessageListener {

    @SuppressWarnings("rawtypes")
    private RedisTemplate rt;

    @SuppressWarnings("rawtypes")
    public RedisTemplate getRt() {
        return rt;
    }

    @SuppressWarnings("rawtypes")
    public void setRt(RedisTemplate rt) {
        this.rt = rt;
    }

    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 获取消息
        byte[] body = message.getBody();
        // 使用值序列化器转换
        String msgBody = (String)getRt().getValueSerializer().deserialize(body);
        System.out.println(msgBody);
        // 获取channel
        byte[] channel = message.getChannel();
        // 使用字符串序列化器转换
        String channelStr = (String)getRt().getStringSerializer().deserialize(channel);
        System.out.println(channelStr);
        // 渠道名称转换
        String bytesStr = new String(pattern);
        System.out.println(bytesStr);
    }

}

这里我们没有使用注解，所以要去spring.xml中注册bean

<!-- 实例化类 -->
<bean id="redisMsgListener" class="com.codeliu.transaction.RedisMessageListener">
    <property name="rt" ref="redisTemplate"></property>
</bean>

实例化监听类之后还不行，还得给一个监听容器，在Spring中对应的类为RedisMessageListenerContainer，它可以用来监听Redis的发布订阅消息。同样在Spring.xml中进行配置

<!-- 配置监听容器 -->
<bean id="topicContainer" class="org.springframework.data.redis.listener.RedisMessageListenerContainer" destroy-method="destroy">
    <!-- redis连接工厂 -->
    <property name="connectionFactory" ref="connectionFactory"></property>      
    <!-- 连接池，只有线程池生存，才能继续监听 -->
    <property name="taskExecutor">
        <bean class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
            <property name="poolSize" value="3"></property>
        </bean>
    </property>     
    <!-- 消息监听map -->
    <property name="messageListeners">
        <map>
            <!-- 配置监听者,key-ref与bean id保持一致 -->
            <entry key-ref="redisMsgListener">
                <!-- 监听类 -->
                <bean class="org.springframework.data.redis.listener.ChannelTopic">
                    <constructor-arg value="chat"></constructor-arg>
                </bean>
            </entry>
        </map>
    </property>
</bean>

这里配置了线程池，这个线程池将会持续的生存以等待消息传入，而这里配置了容器用id为redisMsgListener的Bean进行渠道chat的监听。当消息通过渠道chat方法的时候，就会使用id为redisMsgListener的Bean处理消息。

下面进行测试

public static void main(String[] args) {
    ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");
    RedisTemplate rt = applicationContext.getBean(RedisTemplate.class);
    String channel = "chat";
    // 向渠道chat发送消息
    rt.convertAndSend(channel, "Hello World!");
}

convertAndSend方法就是向指定的渠道发送消息。

输出

Hello World!
chat
chat

本文的重点是你有没有收获与成长，其余的都不重要，希望读者们能谨记这一点。同时我经过多年的收藏目前也算收集到了一套完整的学习资料，包括但不限于：分布式架构、高可扩展、高性能、高并发、Jvm性能调优、Spring，MyBatis，Nginx源码分析，Redis，ActiveMQ、、Mycat、Netty、Kafka、Mysql、Zookeeper、Tomcat、Docker、Dubbo、Nginx等多个知识点高级进阶干货，希望对想成为架构师的朋友有一定的参考和帮助

需要更详细架构师技能思维导图和以下资料的可以加一下技术交流分享群：“708 701 457”免费获取

Redis必知必会——发布订阅

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

本文标题：Redis必知必会——发布订阅-创新互联
标题网址：https://www.cdcxhl.com/article36/djhdsg.html

成都网站建设公司_创新互联，为您提供服务器托管、外贸网站建设、标签优化、企业建站、网站建设、软件开发

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容