Socket io .NET（開発者向けの仕組み）

Socket.IOは、ウェブクライアントとサーバーがリアルタイムで通信する力を持つJavaScriptライブラリです。 それは2つの部分で構成されています:

Socket IOの部品

• クライアントサイドライブラリ: ブラウザで実行されます。
• サーバーサイドライブラリ: Node.jsで実行されます。

必要なパッケージをインストールする

Visual Studioで .NETアプリケーションにSocket.IOを使用するには、互換性のあるサーバー実装が必要です。 そのような実装の一つが.NET用のSocketIoClientDotNetであり、C#アプリケーションからSocket.IOクライアントがSocket.IOに接続できるようにします。

まず、必要なNuGetパッケージをインストールしてください。 これをPackage Manager Consoleを経由して行うか、プロジェクトファイルにリファレンスを追加することで行うことができます:

Install-Package SocketIoClientDotNet

SocketIoClientDotNetパッケージのスクリーンショット

このコマンドを実行すると、Socket.IOクライアントライブラリがあなた for .NETプロジェクトに組み込まれ、C#アプリケーションがユーザーとシステム間の通信を促進しながらSocket.IOサーバーに接続できるようになります。

C#クライアントに取り掛かる前に、Visual Studioで.NET Coreコンソールアプリを使用した基本的なSocket IOの例を設定しましょう。 これにより、クライアント実装をテストできます。

サーバー実装の作成

以下のコードは、クライアント接続をポート 3000 でリッスンする基本的な Socket.IO サーバーを C# で設定します。クライアントからメッセージが送信されると、サーバーはメッセージをログに記録し、受信を確認するためにクライアントに応答します。

using System;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Quobject.SocketIoClientDotNet.Client;

namespace DemoApp
{
    internal class Program
    {
        static void Main(string[] args)
        {
            // Connect to the Socket.IO server
            var socket = IO.Socket("http://localhost:3000");

            // Listen for the "connect" event
            socket.On(Socket.EVENT_CONNECT, () =>
            {
                Console.WriteLine("Connected to the server!");

                // Emit a message to the server
                socket.Emit("message", "Hello from C# client!");

                // Listen for messages from the server
                socket.On("message", (data) =>
                {
                    Console.WriteLine("Message from server: " + data);
                });
            });

            // Listen for the "disconnect" event
            socket.On(Socket.EVENT_DISCONNECT, () =>
            {
                Console.WriteLine("Disconnected from the server!");
            });

            // Keep the console window open
            Console.ReadLine();
        }
    }
}

using System;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Quobject.SocketIoClientDotNet.Client;

namespace DemoApp
{
    internal class Program
    {
        static void Main(string[] args)
        {
            // Connect to the Socket.IO server
            var socket = IO.Socket("http://localhost:3000");

            // Listen for the "connect" event
            socket.On(Socket.EVENT_CONNECT, () =>
            {
                Console.WriteLine("Connected to the server!");

                // Emit a message to the server
                socket.Emit("message", "Hello from C# client!");

                // Listen for messages from the server
                socket.On("message", (data) =>
                {
                    Console.WriteLine("Message from server: " + data);
                });
            });

            // Listen for the "disconnect" event
            socket.On(Socket.EVENT_DISCONNECT, () =>
            {
                Console.WriteLine("Disconnected from the server!");
            });

            // Keep the console window open
            Console.ReadLine();
        }
    }
}

コードの説明

スニペットでは、まず IO.Socket("http://localhost:3000") を呼び出して Socket.IO クライアント インスタンスを作成し、クライアント マシンのポート 3000 で実行されているローカル サーバーに接続します。

接続が成功すると (Socket.EVENT_CONNECT)、サーバーに接続されたことを示すメッセージが出力されます。

次に、socket.Emit("message", "Hello from C# client!") を使用してクライアントからサーバーにメッセージを送信します。 これにより、"Hello from C# client!"という内容のメッセージがサーバーに送信されます。

次に、socket.On("message", (data) => { ... }) を使用して"message" イベントのためにコールバックを登録することで、サーバーからのメッセージをリッスンします。 })。 クライアントからサーバーへの接続が切断された場合 (Socket.EVENT_DISCONNECT`)、切断を示すメッセージを印刷します。

クライアントからサーバーへの接続が切断された場合 (Socket.EVENT_DISCONNECT)、切断を示すメッセージを出力します。

最後に、Console.ReadLine() メソッドは、プログラムが実行直後に終了しないように、コンソール ウィンドウを開いたままにします。

コードのスクリーンショット

ロングポーリングは、クライアント（通常はWebブラウザ）とサーバーの間でライブラリを使用してメッセージを送信するWeb開発で使用される技法です。

連続したポーリングを必要とせずに、クライアントが受信できるイベントをサーバー側でトリガーすることにより、リアルタイム通信を可能にします。 この方法は、チャットアプリケーションや株式ティッカーなどの即時更新が要求されるアプリケーションに特に有用です。 このメソッドは、チャットアプリケーションや株価ティッカーなど、即時の更新が必要なアプリケーションに特に便利です。

WebSocketは、単一のTCP接続を介して全二重通信チャンネルを確立することによって双方向通信を促進します。

このプロトコルは、クライアント（通常はWebブラウザ）とサーバー間でリアルタイムの対話を可能にし、両方の当事者が非同期でメッセージを交換できるようにします。 このプロトコルは、通常はウェブブラウザーであるクライアントとサーバー間でのリアルタイムのインタラクションを可能にし、双方が非同期的にメッセージを交換できるようにします。

クライアントは、WebSocket接続を確立する意思を示すWebSocketハンドシェイク要求をサーバーに送信します。

ハンドシェイク要求を受信すると、サーバーはWebSocketハンドシェイク応答を返し、接続が正常に確立されたことを示します。 ハンドシェイク要求を受信すると、サーバーは WebSocket ハンドシェイク応答を返し、接続が正常に確立されたことを示します。 WebSocket 接続を介して送信されるメッセージは、任意のフォーマット (例: テキストまたはバイナリ) であり、非同期に送受信できます。

Visual Studio に IronPDF をインストールするか、コマンドラインから NuGet パッケージマネージャーを使用します。 - ツール -> NuGet パッケージマネージャ -> パッケージマネージャ コンソール

IronPDFのコード例

Install-Package IronPdf

IronPDFのコード例

IronPDFを使ってバイナリデータをPDFファイルに変換する簡単な例を以下に示します。GeneratePDFメソッドを呼び出し、上記の例と同様にデータをパラメータとして渡します。

using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;

namespace SocketIO.Demo
{
    class Program
    {
        static async Task Main(string[] args)
        {
            // The WebSocket URI
            string uri = "wss://echo.websocket.org";

            // Creating a new WebSocket connection
            using (ClientWebSocket webSocket = new ClientWebSocket())
            {
                await webSocket.ConnectAsync(new Uri(uri), CancellationToken.None);
                Console.WriteLine("Connected to the server");

                // Sending data over the WebSocket
                byte[] sendBuffer = new byte[] { 1, 2, 3, 4 };
                await webSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Binary, true, CancellationToken.None);
                Console.WriteLine("Data sent to the server");

                // Receiving data from the WebSocket
                byte[] receiveBuffer = new byte[1024];
                WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
                byte[] data = new byte[result.Count];
                Array.Copy(receiveBuffer, data, result.Count);
                Console.WriteLine("Received data: " + BitConverter.ToString(data));

                // Data to generate in PDF file
                string pdfData = BitConverter.ToString(data);
                PDFGenerator.GeneratePDF(pdfData);
            }
        }
    }
}

using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;

namespace SocketIO.Demo
{
    class Program
    {
        static async Task Main(string[] args)
        {
            // The WebSocket URI
            string uri = "wss://echo.websocket.org";

            // Creating a new WebSocket connection
            using (ClientWebSocket webSocket = new ClientWebSocket())
            {
                await webSocket.ConnectAsync(new Uri(uri), CancellationToken.None);
                Console.WriteLine("Connected to the server");

                // Sending data over the WebSocket
                byte[] sendBuffer = new byte[] { 1, 2, 3, 4 };
                await webSocket.SendAsync(new ArraySegment<byte>(sendBuffer), WebSocketMessageType.Binary, true, CancellationToken.None);
                Console.WriteLine("Data sent to the server");

                // Receiving data from the WebSocket
                byte[] receiveBuffer = new byte[1024];
                WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(receiveBuffer), CancellationToken.None);
                byte[] data = new byte[result.Count];
                Array.Copy(receiveBuffer, data, result.Count);
                Console.WriteLine("Received data: " + BitConverter.ToString(data));

                // Data to generate in PDF file
                string pdfData = BitConverter.ToString(data);
                PDFGenerator.GeneratePDF(pdfData);
            }
        }
    }
}

PDF 生成クラスのコード

using IronPdf;

namespace SocketIO.Demo
{
    public class PDFGenerator
    {
        public static void GeneratePDF(string data)
        {
            IronPdf.License.LicenseKey = "Your-Licence-Key-Here";
            Console.WriteLine("PDF Generating Started...");

            // Instantiate Renderer
            var renderer = new ChromePdfRenderer();
            Console.WriteLine("PDF Processing ....");

            var pdf = renderer.RenderHtmlAsPdf($"<h1>Received Data</h1><p>{data}</p>");
            string filePath = "Data.pdf";
            pdf.SaveAs(filePath);
            Console.WriteLine($"PDF Generation Completed. File Saved as {filePath}");
        }
    }
}

using IronPdf;

namespace SocketIO.Demo
{
    public class PDFGenerator
    {
        public static void GeneratePDF(string data)
        {
            IronPdf.License.LicenseKey = "Your-Licence-Key-Here";
            Console.WriteLine("PDF Generating Started...");

            // Instantiate Renderer
            var renderer = new ChromePdfRenderer();
            Console.WriteLine("PDF Processing ....");

            var pdf = renderer.RenderHtmlAsPdf($"<h1>Received Data</h1><p>{data}</p>");
            string filePath = "Data.pdf";
            pdf.SaveAs(filePath);
            Console.WriteLine($"PDF Generation Completed. File Saved as {filePath}");
        }
    }
}