NonSoft

POP3(SSL無し)でメール受信
(TcpClientソケット通信)サンプル(C#.NET)


 サンプル(ソース/コード)
ソケット通信(System.Net.Sockets.TcpClient)によるPOP3メール受信(SSL無し)のサンプルです。
メールで送受信されているコマンドとレスポンスの参考になると思います。

POP3サーバーで使用されるコマンド(CAPA/STAT/LIST/UIDL/DELE)は沢山ありますが、
このサンプルではRETRによるメール受信のみシンプルにまとめています。

SSL(セキュリティで保護された接続)による暗号化も可能ですので、
別のサンプルで記述します。

簡単にメール送受信したい方は、こちらのDLLをオススメします。
メール送信/受信DLL(VB.NET/C#.NET)

VB.NET版のサンプルソースはこちらです。
POP3(SSL無し)でメール受信(TcpClientソケット通信)サンプル(VB.NET)

メール関係のその他のサンプルはこちらです。
メール送信/メール受信サンプル(VBS/VBA)
メール送信(SMTP認証/POP認証)のサンプル(C#.NET)
SMTP(SSL無し)でメール送信(TcpClientソケット通信)サンプル(C#.NET)
SMTP(SSL有り)でメール送信(TcpClientソケット通信)サンプル(C#.NET)
SMTP(TLS有り)でメール送信(TcpClientソケット通信)サンプル(C#.NET)
POP3(SSL有り)でメール受信(TcpClientソケット通信)サンプル(C#.NET)
IMAP(SSL無し)でメール受信(TcpClientソケット通信)サンプル(C#.NET)
IMAP(SSL有り)でメール受信(TcpClientソケット通信)サンプル(C#.NET)

メール関係のツールはこちらです。
指令メール実行
受信メールを監視しメールタイトルのキーワードに対応したプログラムを実行するツールです。
ファイル監視人
ファイルやフォルダの更新時にメッセージ表示またはメール送信するツールです。
フォルダ監視人
フォルダ内のファイル更新時に更新通知(差分メール等)、指定プログラム実行するツールです。
PC状況メール通知(PcEvMail)
PC起動/PC終了/ログイン/ログアウト/ファイル更新時にメール通知/ログ出力するツールです。

ソケット通信関係のサンプルはこちらにもあります。
ソケット(TCP/IP)通信関係のサンプル

★フォーム(Form1.cs)
public partial class Form1 : Form
{
    private String cset = "ISO-2022-JP";
    private String serv = "pop.xxx.com";
    private int port = 110;
    private String user = "user";
    private String pass = "pass";

    // (SSL無し)POP3でメール受信(TcpClientソケット通信)サンプル
    // ヤフー(pop.mail.yahoo.co.jp)やニフティー(pop.nifty.com)でメール受信
    private void button1_Click(object sender, EventArgs e)
    {
        // TcpClientソケット通信定義
        System.Net.Sockets.NetworkStream stream;
        System.Net.Sockets.TcpClient client;

        // POPサーバーに接続
        client = new System.Net.Sockets.TcpClient();
        client.Connect(serv, port);

        // SSL無しの実装--------------------------------------------------------------
        // 通信開始(SSL無し)
        stream = client.GetStream();
        // ---------------------------------------------------------------------------

        // POPサーバー接続時のレスポンス受信
        String rstr;
        rstr = StreamWriteAndRead(stream, "", cset);
        if (rstr.StartsWith("+") == false)
        {
            throw new Exception("エラー:" + rstr);
        }

        // USERの送信
        rstr = StreamWriteAndRead(stream, "USER " + user + "\r\n", cset);
        if (rstr.StartsWith("+") == false)
        {
            throw new Exception("エラー:" + rstr);
        }

        // PASSの送信
        rstr = StreamWriteAndRead(stream, "PASS " + pass + "\r\n", cset);
        if (rstr.StartsWith("+") == false)
        {
            throw new Exception("エラー:" + rstr);
        }

        // RETRの送信
        rstr = StreamWriteAndRead(stream, "RETR 1" + "\r\n", cset);
        if (rstr.StartsWith("+") == false)
        {
            throw new Exception("エラー:" + rstr);
        }

        // メールの表示
        System.Diagnostics.Debug.WriteLine(rstr);

        // QUITの送信
        rstr = StreamWriteAndRead(stream, "QUIT" + "\r\n", cset);
        if (rstr.StartsWith("+") == false)
        {
            throw new Exception("エラー:" + rstr);
        }
    }

    /// <summary>
    /// メールサーバとの送受信
    /// </summary>
    /// <param name="stm">メールサーバ通信ストリーム</param>
    /// <param name="req">リクエスト(コマンド)</param>
    /// <param name="cts">文字コード</param>
    /// <returns>レスポンス</returns>
    private String StreamWriteAndRead(
        System.Net.Sockets.NetworkStream stm, String req, String cst)
    {
        // メールサーバへリクエスト送信
        if (req != "")
        {
            Byte[] sdat;
            sdat = System.Text.Encoding.GetEncoding(cst).GetBytes(req);
            stm.Write(sdat, 0, sdat.Length);
            stm.Flush();
        }

        // メールサーバからのレスポンス受信
        String rstr = "";
        Byte[] rdat = new Byte[] { };
        Array.Resize<Byte>(ref rdat, 1024 * 1024);
        int l = stm.Read(rdat, 0, rdat.Length);
        if (l > 0)
        {
            Array.Resize<Byte>(ref rdat, l);
            rstr = System.Text.Encoding.GetEncoding(cst).GetString(rdat);
        }
        else
        {
            throw new Exception("Read Error.");
        }

        // メール受信の時の処理
        if (rstr.StartsWith("+") == true &&
            req.ToUpper().StartsWith("RETR"))
        {
            do
            {
                Array.Resize<Byte>(ref rdat, 1024 * 1024);
                l = stm.Read(rdat, 0, rdat.Length);
                if (l > 0)
                {
                    Array.Resize<Byte>(ref rdat, l);
                    rstr +=
                        System.Text.Encoding.GetEncoding(cst).GetString(rdat);
                }
                else
                {
                    throw new Exception("Read Error.");
                }
            } while (rstr.EndsWith("." + "\r\n") == false) ;
        }

        // レスポンス応答
        return rstr;
    }
}