【正文】 start serving up frames //初始化成功，現(xiàn)在，啟動(dòng)服務(wù)器發(fā)送幀 DoIt(cam, serv, sw, myImageCodecInfo, myEncoderParameters)。 [0] = myEncoderParameter。 myEncoderParameter = new EncoderParameter(, JPEGQUALITY)。 myImageCodecInfo = GetEncoderInfo(image/jpeg)。 += new TcpSend(Send)。 += new TcpConnected(Disconnected)。 serv = new TcpServer(TCPLISTENPORT, ()[3])。 bShutDown = false。 // Set up logging //建立日志記錄 StreamWriter sw = (d:\)。 ImageCodecInfo myImageCodecInfo。 Capture cam = null。 // Depends on video device caps const long JPEGQUALITY = 30。 // Depends on video device caps. Generally 430. const int VIDEOWIDTH = 640。 } public void Run() { const int VIDEODEVICE = 0。 } /// summary /// Stop this service. /// 停止服務(wù) /// The Run() Method tests for this thread state each second /// 每秒都為這個(gè)進(jìn)程啟動(dòng)方法測(cè)試 /// /summary protected override void OnStop() { // Set exit condition //設(shè)置退出狀態(tài) bShutDown = true。//實(shí)例化進(jìn)程 thread = new Thread(starter)。 private volatile int iConnectionCount。 private ManualResetEvent ConnectionReady。 } } region Member Variables private const int MAXOUTSTANDINGPACKETS = 3。 } else { = false。 WebCamService ServiceToRun = new WebCamService() 。 } } ( disposing )。 = WebCamService。 public WebCamService() { InitializeComponent()。 public delegate void TcpReceive(Object sender, ref object o, ref byte [] b, int ByteCount)。 } } } public delegate void TcpConnected(Object sender, ref object o)。 byBuff = new byte[256]。 public object obj。 } // Wrapper for each client (stored in m_aryClients) internal class SockWrapper { // The buffer is used by receive public Socket Client。 } catch {} // Remove it from the array try { ( s )。 } } } } // Remove a connection from the list of active connections private void RemoveConnection(SockWrapper s) { try { ( )。 } else { // If no data was received then the connection is probably dead RemoveConnection(s)。 // Restablish the callback AsyncCallback receiveData = new AsyncCallback( OnReceivedData )。 lock (this) { if (!m_bShuttingDown) { // Check if we got any data try { int nBytesRec = ( ar )。T setup // the async listen, and DO set the event // to say we are done. ()。 } else { // If we are in shutdown mode, DON39。 ( , 0, , , receiveData, s )。 // Fire the Connected event if (Connected != null) Connected(this, ref )。 lock (this) { if (!m_bShuttingDown) { // Wrap the client and add it to the array SockWrapper s = new SockWrapper(client)。 } catch { // Ignore the error. If the client is dead, OnReceiveData // will be called to close the connection. I would remove it // anyway, except bad things happen if you remove an entry // from a list while using foreach. } } // Client has connected private void OnConnectRequest( IAsyncResult ar ) { // Get the listener and client Socket listener = (Socket)。 if (Send != null) Send(this, ref , ref bSend)。 } } private void _SendToAll(byte [] b, int iLength) { lock (this) { if (!m_bShuttingDown) { foreach (SockWrapper s in m_aryClients) { _SendOne(s, b, iLength)。 } catch { m_bShuttingDown = true。 ( MAXCONNECTIONS )。s IP address m_sockListener = new Socket( , , )。 m_bShuttingDown = false。 private void _TcpServer(int nPortListen, IPAddress ip) { try { // Initialize member vars m_aryClients = new ArrayList(5)。 public event TcpReceive DataReceived。 } } public event TcpConnected Connected。 } public void SendToAll(byte [] b) { _SendToAll(b, )。s no way to clean up // nicely. Moral: Always call Dispose. //Dispose()。 ShutDownReady = null。 ()。 lock (this) { // close everything down ()。 t = new TcpClient((), )。