在Java中使用Redis实现消息与订阅，主要有两种方式：使用列表（List）作为消息队列，以及使用发布/订阅（Pub/Sub）模式。以下是这两种方式的详细说明和代码示例：

1. 使用列表（List）作为消息队列

在Redis中，列表（List）是一种双向链表结构，可以用作消息队列。生产者使用lpush命令将消息压入列表头部，消费者使用rpop命令从列表尾部弹出消息。这种方式是阻塞式的，如果列表中没有消息，消费者会等待直到有消息到达。

生产者代码示例：

java

class MessageProducer extends Thread {
    public static final String MESSAGE_KEY = "message:queue";
    private volatile int count;

    public void putMessage(String mess) {
        Jedis jedis = new Jedis("IP", 6379);
        jedis.auth("password");
        Long size = jedis.lpush(MESSAGE_KEY, mess);
        System.out.println("Put " + Thread.currentThread().getName() + " put message " + count);
        count++;
    }

    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            putMessage("message" + count);
            try {
                Thread.sleep(600);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

消费者代码示例：

java

class MessageConsumer extends Thread {
    public static final String MESSAGE_KEY = "message:queue";
    private volatile int count;

    public void consumerMessage() {
        Jedis jedis = new Jedis("IP", 6379);
        jedis.auth("password");
        String message = jedis.rpop(MESSAGE_KEY);
        System.out.println("Pop " + Thread.currentThread().getName() + " consumer message = " + message);
        count++;
    }

    @Override
    public void run() {
        for (int i = 0; i < 9; i++) {
            consumerMessage();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

2. 使用发布/订阅（Pub/Sub）模式

Redis的发布/订阅模式是一种消息通信模式，允许发布者（Publisher）向一个或多个订阅者（Subscriber）发送消息。订阅者可以订阅一个或多个频道（Channel），当发布者向频道发送消息时，所有订阅该频道的订阅者都会收到消息。

发布消息：

java

redisTemplate.convertAndSend("channel_name", "message_payload");

在上述代码中，"channel_name"是消息的通道名称，"message_payload"是要发布的消息内容。

订阅消息： 首先，创建一个MessageListener实现类来处理接收到的消息：

java

@Component
public class RedisMessageListener implements MessageListener {
    @Autowired
    private RedisTemplate redisTemplate;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 获取消息
        byte[] messageBody = message.getBody();
        // 使用值序列化器转换
        Object msg = redisTemplate.getValueSerializer().deserialize(messageBody);
        // 获取监听的频道
        byte[] channelByte = message.getChannel();
        // 使用字符串序列化器转换
        Object channel = redisTemplate.getStringSerializer().deserialize(channelByte);
        // 渠道名称转换
        String patternStr = new String(pattern);
        System.out.println(patternStr);
        System.out.println("---频道---: " + channel);
        System.out.println("---消息内容---: " + msg);
    }
}

然后，配置消息监听容器和消息监听适配器：

java

@Configuration
public class RedisConfig {
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory factory, RedisMessageListener listener) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        //订阅频道redis.news 和 redis.life  这个container 可以添加多个 messageListener
        container.addMessageListener(listener, new ChannelTopic("redis.life"));
        container.addMessageListener(listener, new ChannelTopic("redis.news"));
        return container;
    }
}

这样，当有消息发布到"redis.life"或"redis.news"频道时，RedisMessageListener中的onMessage方法会被调用，处理接收到的消息。

这两种方式都可以在Java中实现Redis的消息与订阅功能，选择哪一种取决于具体的应用场景和需求。