【C#】Socket通信でファイル転送をやってみた

// マニュアルリセットイベントのインスタンスを生成
private static ManualResetEvent sendDone = new ManualResetEvent(false);     //送信シグナル用

public async Task<bool> StartClient(string ipaddress, int port, string filepath)
{
    //シグナルをリセット
    sendDone.Reset();

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

        // TCP/IPのソケットを作成
        Socket client = new Socket(IPAddress.Parse(ipaddress).AddressFamily, SocketType.Stream, ProtocolType.Tcp);

        // エンドポイント（IPアドレスとポート）へ接続
        var task = client.ConnectAsync(endpoint);
        if (await Task.WhenAny(task, Task.Delay(5000)) != task)
        {
            //タイムアウトの例外
            throw new SocketException(10060);
        }

        var filename = Path.GetFileName(filepath);  // ファイルパスからファイル名を取得
        var preBuffer = Encoding.UTF8.GetBytes(filename + "<EOL>");
        var postBuffer = Encoding.UTF8.GetBytes("<EOL>");

        // ファイルの送信
        client.BeginSendFile(filepath, preBuffer, postBuffer, TransmitFileOptions.UseDefaultWorkerThread, new AsyncCallback(SendFileCallback), client);
        sendDone.WaitOne();  //送信シグナルになるまで待機

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

    return true;
}

private void SendFileCallback(IAsyncResult ar)
{
    try
    {
        // ソケットを取得
        Socket client = (Socket)ar.AsyncState;

        // 非同期送信を終了
        client.EndSendFile(ar);
        Debug.WriteLine("送信完了");

        // シグナル状態にし、メインスレッドの処理を続行する
        sendDone.Set();
    }
    catch (Exception e)
    {
        Debug.WriteLine(e.ToString());
    }
}

//マニュアルリセットイベントのインスタンスを生成
public ManualResetEvent allDone = new ManualResetEvent(false);

//TCP/IPの接続開始処理
public async Task<bool> StartListening(int port)
{
    Debug.WriteLine("TCP/IP接続開始");

    // IPアドレスとポート番号を取得
    IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Any, port);

    // TCP/IPのソケットを作成
    Socket TcpServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

    try
    {
        TcpServer.Bind(localEndPoint);  // ローカルエンドポイントにバインド
        TcpServer.Listen(1);            // 待ち受け開始

        // 非同期で接続要求待ち受け
        Debug.WriteLine("接続待機中...");
        var socket = await Task.Run(() => TcpServer.Accept());

        using (NetworkStream ns = new NetworkStream(socket))
        using (MemoryStream ms = new MemoryStream())
        {
            // クライアントからのデータを受信
            byte[] gdata = new byte[256];
            do
            {
                int dataSize = await ns.ReadAsync(gdata, 0, gdata.Length);
                if (dataSize == 0) return false;
                await ms.WriteAsync(gdata, 0, dataSize);
            }
            while (ns.DataAvailable);
            byte[] bytes = ms.GetBuffer();
            Debug.WriteLine("データの受信完了");

            // 受信データを分割
            var pattern = Encoding.ASCII.GetBytes("<EOL>");
            var index = PatternAt(bytes, pattern);
            if (index.Count() != 2) return false;

            byte[] fbytes, dbytes;
            SplitByte(bytes, index[0], index[1], out fbytes, out dbytes);
            Debug.WriteLine("受信データの分割完了");
            // ファイルを作成
            CreateFile(fbytes, dbytes);
            Debug.WriteLine("ファイル作成完了");
        }
    }
    catch (Exception ex)
    {
        Debug.WriteLine(ex.ToString());
    }

    return false;
}

//パターンに一致するバイト型配列のインデックスを検索
private List<int> PatternAt(byte[] source, byte[] pattern)
{
    var index = new List<int>();
    for (int i = 0; i < source.Length; i++)
    {
        if (source.Skip(i).Take(pattern.Length).SequenceEqual(pattern))
        {
            index.Add(i);
        }
    }
    return index;
}

//バイト型配列をファイル名とデータに分割
private void SplitByte(byte[] source, int findex, int dindex, out byte[] fbytes, out byte[] dbytes)
{
    var flenth = findex;
    fbytes = new byte[flenth];
    Array.Copy(source, 0, fbytes, 0, flenth);

    var dlenth = dindex - findex - 5;
    dbytes = new byte[dlenth];
    Array.Copy(source, findex + 5, dbytes, 0, dlenth);
}

private void CreateFile(byte[] fbytes, byte[] dbytes)
{
    try
    {
        var filename = Encoding.UTF8.GetString(fbytes);
        var path = Environment.GetFolderPath(Environment.SpecialFolder.DesktopDirectory); // 保存先パス
        using (FileStream fs = new FileStream(path + "\\" + filename, FileMode.Create))
        {
            fs.Write(dbytes, 0, dbytes.Length);
        }
    }
    catch (Exception ex)
    {
        Debug.WriteLine(ex.Message);
    }
}

public partial class MainWindow : Window
{
    tcpclient client = new tcpclient();

    public MainWindow()
    {
        InitializeComponent();
    }

    private async void btnConnection_Click(object sender, RoutedEventArgs e)
    {
        //ファイルを転送
        await client.StartClient(txtIPaddress.Text, int.Parse(txtPort.Text), txtPath.Text);
    }

    private void btnPath_Click(object sender, RoutedEventArgs e)
    {
        //ファイルのパスを取得
        txtPath.Text = "";
        txtPath.Text = SelectPath();
    }

    private string SelectPath()
    {
        var path = "";

        // ダイアログのインスタンスを生成
        var dialog = new OpenFileDialog();
        if (dialog.ShowDialog() == true)
        {
            path = dialog.FileName;  // 選択されたファイル名を取得
        }

        return path;
    }
}

public partial class MainWindow : Window
{
    tcpserver tcp = new tcpserver();

    public MainWindow()
    {
        InitializeComponent();
    }

    private async void BtnStart_Click(object sender, RoutedEventArgs e)
    {
        btnStart.IsEnabled = false;

        if (!await tcp.StartListening(int.Parse(txtPort.Text)))
        {
            btnStart.IsEnabled = true;
        }
    }
}