Rsocket服务器如何向客户端发送消息？以及如何在js中使用Channel？

import { RSocketClient, JsonSerializer, IdentitySerializer } from 'rsocket-core';
import RSocketWebSocketClient from 'rsocket-websocket-client';

// 创建RSocket连接
const client = new RSocketClient({
  serializers: {
    data: JsonSerializer,
    metadata: IdentitySerializer,
  },
  setup: {
    // 连接RSocket服务器的WebSocket地址
    // 替换成实际的RSocket服务器地址
    transport: new RSocketWebSocketClient({ url: 'ws://localhost:8080/rsocket' }),
  },
});

// 建立连接
client.connect().subscribe({
  onComplete: (socket) => {
    // 连接成功后，可以使用socket发送和接收消息

    // 发送请求并接收响应
    socket.requestResponse({
      data: 'Hello RSocket!', // 请求的数据
      metadata: '', // 元数据，可以用于标识请求类型等
    }).subscribe({
      onComplete: (response) => {
        // 处理响应
        console.log('Response:', response.data);
      },
      onError: (error) => {
        // 处理错误
        console.error('Error:', error);
      },
    });

    // 订阅主题并接收消息
    socket.requestStream({
      data: 'news', // 订阅的主题
      metadata: '', // 元数据
    }).subscribe({
      onNext: (response) => {
        // 处理收到的消息
        console.log('Received:', response.data);
      },
      onError: (error) => {
        // 处理错误
        console.error('Error:', error);
      },
    });
  },
  onError: (error) => {
    // 连接错误处理
    console.error('Connection Error:', error);
  },
});