1

このコードを使用して、一部のサイトのブラウザーにカスタム メッセージを送信する HttpListner を作成しました。コードは正常に動作し、メッセージが表示されます。しかし、Httpserver を停止しようとすると、この行でアプリケーションがブロックされます _listenerThread.Join(); 。以下は私のコードです

private readonly HttpListener _listener;
private readonly Thread _listenerThread;
private readonly Thread[] _workers;
private readonly ManualResetEvent _stop, _ready;
private Queue<HttpListenerContext> _queue;


public HttpServer(int MaxThreads)
{
    _workers = new Thread[MaxThreads];
    _queue = new Queue<HttpListenerContext>();
    _stop = new ManualResetEvent(false);
    _ready = new ManualResetEvent(false);
    _listener = new HttpListener();
    _listenerThread = new Thread(HandleRequests);
}

private void HandleRequests()
{
    while (_listener.IsListening)
    {

        var context = _listener.BeginGetContext(GetContextCallBack, null);

        if (0 == WaitHandle.WaitAny(new WaitHandle[] { _stop, context.AsyncWaitHandle }))
        {
            return;
        }
    }
}

private void GetContextCallBack(IAsyncResult result)
{
    try
    {
        lock(_queue)
        {
            _queue.Enqueue(_listener.EndGetContext(result));                   
            _ready.Set();
         }
    }
    catch
    { return; }

}

public void Start(int port)
{
    _listener.Prefixes.Add(String.Format(@"http://+:{0}/", port));
    _listener.Start();
    _listenerThread.Start();

    for (int i = 0; i < _workers.Length; i++)
    {
        _workers[i] = new Thread(Worker);
        _workers[i].Start();
    }
}

private void Worker(object obj)
{
    WaitHandle[] wait = new[] { _ready, _stop };
    while (0 == WaitHandle.WaitAny(wait))
    {
        HttpListenerContext context;
        lock (_queue)
        {
            if (_queue.Count > 0)
                context = _queue.Dequeue();
            else
            {
                _ready.Reset();
                continue;
            }
        }

        try
        {
            ProcessRequest(context);
        }
        catch(Exception ex)
        {
            MessageBox.Show(ex.Message + ex.StackTrace);
        }

    }
}

public void Dispose()
{
    Stop();
}

private void Stop()
{
    try
    {
        _stop.Reset();
        _listenerThread.Join();
        foreach (Thread worker in _workers)
        {
            worker.Join();
        }
        _listener.Stop();
        App.Current.MainWindow.Close();

    }
    catch(Exception ex)
    {
        MessageBox.Show(ex.Message + ex.StackTrace);
    }
}


public void  ProcessRequest(HttpListenerContext context)
{
    HttpListenerRequest request = context.Request;
    HttpListenerResponse response = context.Response;

    System.Text.StringBuilder sb = new StringBuilder();

    sb.Append("");
    sb.Append(string.Format("HttpMethod: {0}", request.HttpMethod));
    sb.Append(string.Format("Uri:        {0}", request.Url.AbsoluteUri));
    sb.Append(string.Format("LocalPath:  {0}", request.Url.LocalPath));
    foreach (string key in request.QueryString.Keys)
    {
        sb.Append(string.Format("Query:      {0} = {1}", key, request.QueryString[key]));
    }

    sb.Append("");

    string responseString = sb.ToString();
    byte[] buffer = System.Text.Encoding.UTF8.GetBytes(responseString);
    response.ContentLength64 = buffer.Length;

    using (System.IO.Stream outputStream = response.OutputStream)
    {
        outputStream.Write(buffer, 0, buffer.Length);
    }
}

このコードは、カスタム メッセージを Web ブラウザーに送信しようとしている他のユーザーにも役立つ可能性があります。

4

1 に答える 1

0

これは、「停止」スレッドの最初の問題です。

_listenerThread.Join();
...
_listener.Stop();

リスナーにリスニングを停止するように指示する前に、リスナースレッドが停止するのを待っています...しかし、リスナースレッドには次のものがあります。

private void HandleRequests()
{
    while (_listener.IsListening)
    {
        ...
    }
}

...そのため、リスナーが停止した後にのみ終了します。基本的にデッドロックがあります。停止コードの順序を変更する必要があります。

_listener.Stop();
_listenerThread.Join();
...

さらに、この行：

_stop.Reset();

次のようにする必要があります。

_stop.Set();

停止していることを知らせたいので、信号をクリアしないでください。

于 2013-07-05T14:52:47.187 に答える