Redis订阅和发布 这个功能前面也有很多社友分享了，有个朋友问JF里面咋配合使用，就给了一个 Test类例子，这里分享一下~
http://www.jfinal.com/doc/8-3

新例子，提PR后的测试类：
https://gitee.com/jfinal/jfinal/pulls/53/files

//订阅
//Redis.use().subscribe(new JedisPubSub(){...}, "MyJedisPubSub");

//发布
//Redis.use().publish("MyJedisPubSub", "{...消息内容...}");

//例子代码如：
package com.jfinal.plugin.redis;

import com.jfinal.json.JsonManager;
import com.jfinal.json.MixedJsonFactory;
import com.jfinal.kit.JsonKit;
import com.jfinal.kit.Kv;
import com.jfinal.plugin.activerecord.DbKit;
import org.junit.Test;
import redis.clients.jedis.JedisPubSub;

public class RedisTest {

    /**
     * 订阅消息 , 先运行
     */
    @Test
    public void subscribe() {
        JsonManager.me().setDefaultJsonFactory(new MixedJsonFactory());
        RedisTest.startRedis();
        Redis.use().subscribe(new JedisPubSub() {
            public void onMessage(String channel, String message) {
                System.out.println("channel=" + channel
                        + " \t message=" + message);
                Kv kv = JsonKit.parse(message, Kv.class);
                System.out.println(kv.getStr("data")
                        + kv.getInt("order"));
            }
        }, "RedisTest");
        System.out.println("订阅后代码会阻塞监听发布的内容,这里打印不出来");
    }

    /**
     * 发布消息 , 后运行
     */
    @Test
    public void publish() {
        RedisPlugin rp = RedisTest.startRedis();
        for (int i = 0; i < 10000; i++) {
            String message = JsonKit.toJson(Kv.by("order", i)
                    .set("data", "你好！"));
            Redis.use().publish("RedisTest", message);
        }
        System.out.println("完毕");
        rp.stop();
    }

    /**
     * 再执行模拟第二个订阅端，半路接受消息，然后再取消订阅
     */
    @Test
    public void subscribeThread() throws InterruptedException {
        JsonManager.me().setDefaultJsonFactory(new MixedJsonFactory());
        RedisTest.startRedis();
        JedisPubSub jedisPubSub = Redis.use().subscribeThread(new JedisPubSub() {
            public void onMessage(String channel, String message) {
                System.out.println("channel=" + channel
                        + " \t message=" + message);
                Kv kv = JsonKit.parse(message, Kv.class);
                System.out.println(kv.getStr("data")
                        + kv.getInt("order"));
            }
        }, "RedisTest");
        Thread.sleep(3000);
        System.out.println("取消订阅");
        jedisPubSub.unsubscribe();
        //查看是否停止订阅打印
        Thread.sleep(6000);
        System.out.println("订阅结束");
    }


    public static RedisPlugin startRedis() {
        //临时测试服，方便调试试用，请勿测压
        RedisPlugin rp = new RedisPlugin(DbKit.MAIN_CONFIG_NAME, "182.92.237.152",
                6379, "111111");
        rp.start();
        return rp;
    }

}

jar包在：  https://jfinal.com/download?file=jfinal-4.9-all.zip
maven在：https://mvnrepository.com/artifact/redis.clients/jedis
安装：
https://www.runoob.com/redis/redis-pub-sub.html

 
如果觉得棒！就点个赞哈2333