【C#】クライアント側のSocket通信のタイムアウト設定について

当ページのリンクには広告が含まれています。

URLをコピーしました！

このブログでは、TCP/IP のソケット通信によるクライアント側の通信手順や C# でコードを記述する方法を記事にまとめました。（以下のリンクカードからアクセスすることができます）

あわせて読みたい

【C#】ソケット通信（非同期）でクライアントの処理を記述する方法 C#でソケット（socket）を使って非同期でプログラムを実装することがあったのですが、ソケットについて理解が不十分で苦戦したことがありました。ソケットについて記事…

実際にソケット通信を使う場合、クライアントはサーバーへリクエストを送信する為に頻繁に接続を要求することになります。サーバーが「接続待ち」の状態であれば通信を確立させることができます。

しかし、サーバーが何かしらのトラブルで「接続待ち」をしていなかった時はクライアントの接続は失敗してしまい、永遠に接続を待ち続けることになってしまいます。その為予め設定された一定時間のタイムアウト時間が経過しても応答がない場合には、処理を打ち切って通信を終了する処理を記述する必要があります。

この記事では Soket 通信の接続タイムアウトを任意の時間を設定して通信を終了させる方法について紹介しています。是非参考にしてみてください。

あわせて読みたい

【C#】おすすめする入門書（参考書）５選を紹介！ C# とはマイクロソフトが開発したプログラミング言語であり、Windows向けのアプリケーション開発から、Android向けのアプリケーション開発、Web向けのアプリケーション…

オススメの参考書

C#の使い方が丁寧に解説しており、「基礎からしっかりと学びたい」という初心者の方にオススメの一冊です。サンプルコードも記載してあり、各章の最後に復習問題があるので理解度を確認しながら読み進めることができます。新しい C# のバージョンにも対応している書籍です。

基礎からしっかり学ぶC#の教科書第3版 C# 10対応

Amazon

楽天市場

Yahooショッピング

ポチップ

Soket通信のタイムアウト処理

ここではいくつかの設定方法について紹介します。

WaitHandle.WaitOne(int millisecoundsTimeout)を使用する

クライアントのSoket通信の記事で紹介しているサンプルにタイムアウト処理を追加した例が以下になります。

try
{
    // IPアドレスとポート番号を取得
    IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse(ipaddress), port);

    // TCP/IPのソケットを作成
    using (Socket client = new Socket(IPAddress.Parse(ipaddress).AddressFamily, SocketType.Stream, ProtocolType.Tcp))
    {
        // エンドポイント（IPアドレスとポート）へ接続
        client.BeginConnect(endpoint, new AsyncCallback(ConnectCallback), client);
        if (!connectDone.WaitOne(1000))
        {
            //タイムアウトの例外
            throw new SocketException(10060);
        }

        // 接続後の処理を記述

        // ソケット接続終了
        client.Shutdown(SocketShutdown.Both);
    }
}
catch (Exception e)
{
    Debug.WriteLine(ex.Message);
}

非同期の Soket 通信で接続処理をするBeginConnectは、接続の有無に関わらず次の処理を実行します。なのでManualResetEventのシグナル状態を監視して、接続ができていない場合は、次の処理が実行されないように待機するようにしています。シグナル状態を監視するWaitOne()に数値を引数で渡すと、指定された数値でタイムアウトをします。

ManualResetEventを使いたくない場合は、BeginConnectの返り値であるIAsyncResultからWaitHandleを取得し、WaitOneでタイムアウト処理を記述します。その方法が以下になります。

try
{
    // IPアドレスとポート番号を取得
    IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse(ipaddress), port);

    // TCP/IPのソケットを作成
    using (Socket client = new Socket(IPAddress.Parse(ipaddress).AddressFamily, SocketType.Stream, ProtocolType.Tcp))
    {
        // エンドポイント（IPアドレスとポート）へ接続
        var ar = client.BeginConnect(endpoint, new AsyncCallback(ConnectCallback), client);
        var ret = ar.AsyncWaitHandle.WaitOne(1000, true);
        if (!ret)
        {
            //タイムアウトの例外
            throw new SocketException(10060);
        }

        // 接続後の処理を記述

        // ソケット接続終了
        client.Shutdown(SocketShutdown.Both);
    }
}
catch (Exception ex)
{
    Debug.WriteLine(ex.Message);
}

これらの方法には１つ欠点があり、タイムアウトされるまでデッドロックが発生します。接続シグナルを受信するまでスレッドがブロッグされる為、待機している1秒間はUIが操作不可能になってしまいます。

ブロッグされる同期処理をTask.Run()を使って別スレッドで実行することで、接続待機中のUI画面のフリーズを改善することができます。Task.Run()は簡単に非同期で処理をすることが実現できるのでとても便利です。

try
{
    // IPアドレスとポート番号を取得
    IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse(ipaddress), port);

    // TCP/IPのソケットを作成
    using (Socket client = new Socket(IPAddress.Parse(ipaddress).AddressFamily, SocketType.Stream, ProtocolType.Tcp)) 
    {
        // エンドポイント（IPアドレスとポート）へ接続
        var ar = client.BeginConnect(endpoint, new AsyncCallback(ConnectCallback), client);
        var ret = await Task.Run(() => ar.AsyncWaitHandle.WaitOne(1000, true));
        if (!ret)
        {
            //タイムアウトの例外
            throw new SocketException(10060);
        }

        // 接続後の処理を記述

        // ソケット接続終了
        client.Shutdown(SocketShutdown.Both);
    }
}
catch (Exception ex)
{
    Debug.WriteLine(ex.Message);
}