RSocketWebSocketClient 示例

这里是一个基于 React 和 RSocketWebSocketClient 的示例：

import React, { useState, useEffect } from 'react';
import { RSocketWebSocketClient } from 'rsocket-websocket-client';
import { ReactiveSocket } from 'rsocket-core';

function App() {
  const [socket, setSocket] = useState<ReactiveSocket<any, any>>();
  const [message, setMessage] = useState('');

  useEffect(() => {
    const client = new RSocketWebSocketClient({
      url: 'ws://localhost:8080/rsocket',
    });

    client.connect().subscribe({
      onComplete: (socket) => {
        setSocket(socket);
      },
      onError: (error) => console.error(error),
    });

    return () => {
      client.close();
    };
  }, []);

  const handleSend = () => {
    socket?.fireAndForget({ data: message });
  };

  return (
    <div>
      <input type="text" value={message} onChange={(e) => setMessage(e.target.value)} />
      <button onClick={handleSend}>Send</button>
    </div>
  );
}

export default App;

在这个示例中，我们使用 RSocketWebSocketClient 连接到了一个 WebSocket 服务器，然后在页面上渲染了一个输入框和一个按钮。当用户输入一条消息并点击按钮后，我们使用 ReactiveSocket 的 fireAndForget 方法将消息发送到服务器端。当然，这只是一个简单的示例，你可以根据自己的需求进一步扩展。