我有一个简单的服务器,它等待客户端连接,读取传入流并发回消息。我想要做的是每个连接都由一个单独的线程处理。这是我第一次使用C#中的套接字和线程,而且我发现的大多数例子都非常令人困惑,所以任何帮助或简单的例子都会非常感谢。如何使用线程池来处理新线程中的每个连接
这是我现在所拥有的。
using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
[STAThread]
static void Main(string[] args)
{
TestServer ts = new TestServer();
ts.Start();
}
class TestServer
{
private readonly int port = 48888;
private readonly IPAddress ip = IPAddress.Parse("127.0.0.1");
private TcpListener listener;
public TestServer()
{
this.listener = new TcpListener(this.ip, this.port);
}
public void Start()
{
this.listener.Start();
Console.WriteLine("Server Running...");
Socket s;
Byte[] incomingBuffer;
int bytesRead;
Byte[] Message;
while (true)
{
s = this.listener.AcceptSocket();
incomingBuffer = new Byte[100];
bytesRead = s.Receive(incomingBuffer);
string message = "Hello from the server";
Message = Encoding.ASCII.GetBytes(message.ToCharArray());
s.Send(Message);
}
}
}
ThreadPool.QueeuUserWorkItem(this.processMessage,socket)和ThreadPool.QueueUserWorkItem(new WaitCallBack(processMessage),socket)有什么区别? – Tester101 2009-11-12 19:48:44
@ Tester101:第一个参数必须是WaitCallback类型的委托。你不能直接在那里传递一个方法。所以我将这个方法包装在委托中并通过了它。作为第一个参数,你不能直接传递processMessage。 – bobbyalex 2009-11-13 04:43:51