如何发布订阅redis channel的消息？给出一个scala代码示例

下面是一个使用Scala代码示例来发布和订阅Redis Channel消息的示例：

import redis.clients.jedis.{Jedis, JedisPubSub}

object RedisPubSubExample {
  def main(args: Array[String]): Unit = {
    // 创建Jedis对象
    val jedis = new Jedis("localhost", 6379)

    // 创建并启动订阅线程
    val subscriberThread = new Thread(new Subscriber(jedis))
    subscriberThread.start()

    // 模拟发布消息
    val publisherThread = new Thread(new Publisher(jedis))
    publisherThread.start()

    // 等待订阅线程结束
    subscriberThread.join()
  }
}

class Subscriber(jedis: Jedis) extends Runnable {
  override def run(): Unit = {
    // 创建JedisPubSub对象
    val jedisPubSub = new JedisPubSub() {
      override def onMessage(channel: String, message: String): Unit = {
        println(s"Received message: $message from channel: $channel")
      }
    }

    // 订阅消息
    jedis.subscribe(jedisPubSub, "example-channel")
  }
}

class Publisher(jedis: Jedis) extends Runnable {
  override def run(): Unit = {
    // 发布消息
    jedis.publish("example-channel", "Hello, Redis!")
  }
}

这个示例代码中，我们创建了一个Subscriber类和一个Publisher类来分别订阅和发布消息。在Subscriber类中，我们创建了一个JedisPubSub对象，并实现了onMessage方法来处理接收到的消息。在Publisher类中，我们使用jedis.publish方法来发布消息。

在main方法中，我们创建了一个Jedis对象，并分别创建了一个订阅线程和一个发布线程。然后，我们启动订阅线程和发布线程，并等待订阅线程结束。

当订阅线程接收到消息时，onMessage方法会被调用，并打印出接收到的消息。

请确保已经正确安装和配置了Redis，并将Redis连接参数设置为正确的主机和端口