定義一個基本類(必須繼承自Serializable，否則無效)

public class Car  implements Serializable {
private static final long serialVersionUID = -1L;

private double price;
private String colour;

public Car(double price, String colour){
    this.price = price;
    this.colour = colour;
}

public double getPrice() {
    return price;
}
public void setPrice(double price) {
    this.price = price;
}
public String getColour() {
    return colour;
}
public void setColour(String colour) {
    this.colour = colour;
}

@Override
public String toString(){
    return colour +"car costs $"+price;
}

}

1.訂閱消息：

public static void main(String[] args) {
    RedissonClient redisson = null;
    try{
        Config config = new Config();
        config.useSingleServer().setAddress("127.0.0.1:6379");

        redisson = Redisson.create(config);

        RTopic topic = redisson.getTopic("dw",new SerializationCodec());
        topic.addListener(Car.class, new MessageListener<Car>() {
            @Override
            public void onMessage(CharSequence charSequence, Car car) {
                System.out.println("onMessage:"+charSequence+"; Thread: "+Thread.currentThread().toString());
                System.out.println(car.getColour()+" price : "+car.getPrice());
            }
        });


    }
    catch (Exception ex){
        System.out.println(ex.getMessage());
    }
    finally {

    }
}

2.發(fā)布消息：

public static void main(String[] args) {
    RedissonClient redisson = null;
    try{
        Config config = new Config();
        config.useSingleServer().setAddress("127.0.0.1:6379");

        redisson = Redisson.create(config);

        RTopic topic1 = redisson.getTopic("dw", new SerializationCodec());
        topic1.publish(new Car(120000,"white"));
        topic1.publish(new Car(100000,"black"));
    }
    catch (Exception ex){
        System.out.println(ex.getMessage());
    }
    finally {
        redisson.shutdown();
    }
}

先運(yùn)行訂閱消息的main，再運(yùn)行發(fā)布消息的main。
然后看訂閱消息的控制臺，顯示：

image.png

看運(yùn)行結(jié)果，每次有新消息過來，都會開個新線程去跑的，這點(diǎn)要注意。