利用Redis的队列模式实现消息的发送和订阅，适合分布式场景，Java实现代码

以下是一个使用Redis的发布/订阅模式实现消息发送和接收的Java代码示例。

首先，确保你的环境中已经安装并配置了Redis。

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;
 
public class RedisPubSubExample {
 
    // 发布者
    public static class Publisher {
        public void publishMessage(String channel, String message) {
            Jedis jedis = new Jedis("localhost");
            jedis.publish(channel, message);
            jedis.close();
        }
    }
 
    // 订阅者
    public static class Subscriber extends JedisPubSub {
        @Override
        public void onMessage(String channel, String message) {
            System.out.println("Received Message: " + message + " on channel: " + channel);
        }
 
        @Override
        public void onSubscribe(String channel, int subscribedChannels) {
            System.out.println("Subscribed to channel: " + channel + ", total subscribed: " + subscribedChannels);
        }
 
        @Override
        public void onUnsubscribe(String channel, int subscribedChannels) {
            System.out.println("Unsubscribed from channel: " + channel + ", total subscribed: " + subscribedChannels);
        }
    }
 
    public static void main(String[] args) {
        // 发布消息
        Publisher publisher = new Publisher();
        publisher.publishMessage("my-channel", "Hello, Redis!");
 
        // 订阅消息
        Subscriber subscriber = new Subscriber();
        Jedis jedis = new Jedis("localhost");
        jedis.subscribe(subscriber, "my-channel");
 
        // 注意：main方法会阻塞在这里，直到程序退出。
    }
}

在上述代码中，Publisher 类负责发布消息到指定的频道，Subscriber 类继承自 JedisPubSub 类，并实现了相关的回调方法来处理订阅事件和接收的消息。main 方法展示了如何发布和订阅消息，但请注意，实际生产环境中可能需要处理例如连接管理、异常处理等更复杂的逻辑。