【正文】 DEOHEIGHT = 480。 // zero based index of video capture device to use const int FRAMERATE = 15。 // Need to get out of wait //需要退出等待 ()。 ()。 endregion /// summary /// Set things in motion so your service can do its work. /// 為了服務(wù)器可以工作而設(shè)置的選項 /// /summary protected override void OnStart(string[] args) { ThreadStart starter = new ThreadStart(Run)。 private volatile bool bShutDown。 /// summary /// The thread will run the job. /// The job is the Method Run() below /// /summary protected Thread thread = null。 (ServiceToRun)。 15 if ( ) { ()。 } endregion [STAThread] public static void Main(string[] args) { = Main thread。 } protected override void Dispose( bool disposing ) { if( disposing ) { if (ponents != null) { ()。 } private void InitializeComponent() { ponents = new ()。 } WebCamService 類 : namespace WebCamService { public class WebCamService : ServiceBase { region Required Service Related Methods private ponents = null。 14 public delegate void TcpSend(Object sender, ref object o, ref bool b)。 obj = new object()。 public SockWrapper(Socket client) { Client = client。 public byte [] byBuff。 } catch {} // Fire the Disconnected event if (Disconnected != null) Disconnected(this, ref )。 ()。 } } catch { RemoveConnection(s)。 ( , 0, , , receiveData, s )。 if( nBytesRec 0 ) { if (DataReceived != null) DataReceived(this, ref , ref , nBytesRec)。 } } } // Client has sent data, or has disconnected private void OnReceivedData( IAsyncResult ar ) { // Socket was the passed in object SockWrapper s = (SockWrapper)。T add // the connection to the array, DON39。 // (Re)Setup a callback to be notified of connection requests (new AsyncCallback( OnConnectRequest ) , listener )。 // Set up an async wait for packets from the client AsyncCallback receiveData = new AsyncCallback( OnReceivedData )。 ( s )。 Socket client = ( ar )。 if (bSend) (b, iLength, )。 } } } } private void _SendOne(SockWrapper s, byte [] b, int iLength) { try { bool bSend = true。 throw。 // Setup a callback to be notified of connection requests ( new AsyncCallback( OnConnectRequest ), m_sockListener )。 ( new IPEndPoint( ip, nPortListen ) )。 // Create the listener socket in this machine39。 ShutDownReady = new ManualResetEvent(false)。 public event TcpSend Send。 public event TcpConnected Disconnected。 } public int Connections { get { return 。 } // Send to all connected clients public void SendToAll(MemoryStream m) { _SendToAll((), (int))。 } } } ~TcpServer() { // If Dispose is not called against our class and the destructor is // called, some of the member variables in this class have already // been disposed. Such being the case, there39。 ()。 m_sockListener = null。 } } if (t != null) { // Listen for the async listener to let go. This must be done // outside the crit section since the listener needs to lock it. (3000, false)。 // Connect to the port to trigger the async listener IPEndPoint ep = (IPEndPoint)。 ()。 // Only want one thread to be preforming shutdown at a time. lock (this) { // Have we already shutdown? if (!m_bShuttingDown) { m_bShuttingDown = true。t // cancel the async call. Grr. As a workaround, this routine // makes a connection to the port. The OnConnect routine, recognizing // that we are in shutdown, doesn39。 } 8 // Shut down the listener public void Dispose() { // Shutting down is a real PITA. You can39。 } public TcpServer(int nPortListen) { _TcpServer(nPortListen, GetAddresses()[0])。 // Verify we got an IP address. if( aryLocalAddr == null || 1 ) { throw new Exception( Unable to get local address )。 else IPHostEntry ipEntry = ( strHostName )。 // NOTE: DNS looku