读书人
栏目▼

如何写死循环程序

发布时间： 2012-04-17 15:06:33 作者： rapoo

怎么写死循环程序
我想问一个问题 我想放一段死循环程序到 网站里面去
要怎么弄才能达到以下条件
1.不影响其他使用者
2.不需要有人去点击页面触发
3.网站运行周期内 ,这段程序都要运行
4.特定网站使用者, 可以影响,操作这段程序

[解决办法]
线程中
while(true)
{
}
[解决办法]
发现你的4条要求 我错了
[解决办法]
看样子像是一个游戏的数据读取，显示在网页上是吗。。
[解决办法]
global.asax 中写 可以实现你的要求
[解决办法]

探讨
当有人访问的时候去查不行么~~~~~~

没人访问。。。你在哪里，不停的查啊~~刷啊~~` 也没意义啊~~~~~

[解决办法]
依赖缓存可以用吗
[解决办法]
给程序加1个接收的事件，当需要接收的时候把事件挂上，发现有信息就接收，没有信息的时候就是空闲的；
管理员操作的时候把事件卸下就可以了。
[解决办法]
探讨

没理解引用:
给程序加1个接收的事件，当需要接收的时候把事件挂上，发现有信息就接收，没有信息的时候就是空闲的；
管理员操作的时候把事件卸下就可以了。

[解决办法]
可以做成windows服务，使用开源框架 Topshelf
[解决办法]
探讨

因为要不停的到一个socket里面查值,但是我不想再服务器上面写一个winform跑,
但是又不想写到页面里面, 然后来一个用户, 跑一个实例 ,我只想从头到尾 整个网站内存里面只跑一个实例

[解决办法]
C# code
using System;using System.Collections;using System.Collections.Specialized;using System.Text;using System.Threading;using System.Net.Sockets;using System.Net;using System.Runtime.Serialization;using System.Runtime.Serialization.Formatters.Binary;using System.IO;using System.Data;using System.Windows.Forms;using System.Configuration;using Microsoft.Win32;using System.Diagnostics;using System.Timers;namespace WSGPSGateway{    public partial class TcpServer : Form    {        public TcpServer()        {            InitializeComponent();        }        #region 自定义字段        public static ManualResetEvent allDone = new ManualResetEvent(false);        /// <summary>        /// 监听控件开启状态        /// </summary>        private bool State = true;        /// <summary>        /// 声明一个线程实例        /// </summary>        private Thread mythread;        /// <summary>        /// 服务器端Ip        /// </summary>        private int _port = Convert.ToInt32(ConfigurationManager.AppSettings["Port"]);        /// <summary>        /// 保存客户端所有回话的哈希表        /// </summary>        private Hashtable _transmit_tb = new Hashtable();        /// <summary>        /// 用于接受消息的线程        /// </summary>        private Thread _receviccethread = null;        public struct TCPParameter        {            public string Package;            public string IpAddress;        }        #endregion        #region 监听代码块        //窗体运行        private void TcpServer_Load(object sender, EventArgs e)        {            this.WindowState = FormWindowState.Minimized;            this.Opacity = 0; // 窗体透明度              Form.CheckForIllegalCrossThreadCalls = false;            InitializeComponent();            mythread = new Thread(Listen);            mythread.Start();            System.Timers.Timer atimer = new System.Timers.Timer();            atimer.Elapsed += new System.Timers.ElapsedEventHandler(TimeEvent);            atimer.Interval = 1000;            atimer.Enabled = true;            GC.KeepAlive(atimer);         }        private object threadlock = new object();        //启动监听        private void BtnStart_Click(object sender, EventArgs e)        {            //多线程        }        //启动监听，轮询监听客户机请求并将客户端套接字存入转发表        private void Listen()        {            try            {                IPAddress _ip = IPAddress.Any;                Socket newsoc = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);                newsoc.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);                IPEndPoint locaEp = new IPEndPoint(IPAddress.Any, _port);//建立连接                           newsoc.Bind(locaEp);                newsoc.Listen(100);                allDone.Reset();                newsoc.BeginAccept(new AsyncCallback(onCall), newsoc);//继续接受其他客户端的连接                 allDone.WaitOne();            }            catch (Exception ex)            {               //            }        }        //监听回调        private void onCall(IAsyncResult ar)        {            allDone.Set();            Socket serverSoc = (Socket)ar.AsyncState;            Socket clent = serverSoc.EndAccept(ar);            try            {                if (serverSoc != null)                {                    byte[] comes = new byte[1024];                    EndPoint enp = clent.RemoteEndPoint;                    serverSoc.BeginAccept(new AsyncCallback(onCall), serverSoc);                    while (true)                    {                        int re = clent.Receive(comes, comes.Length, 0);                        clent.Send(Encoding.ASCII.GetBytes("8"));                        TCPParameter parm = new TCPParameter();                        parm.Package = Encoding.UTF8.GetString(comes, 0, re).ToString().Trim();                        parm.IpAddress = clent.RemoteEndPoint.ToString();                        if (parm.Package.Length != 0)                        {                            Receive(parm.Package, parm.IpAddress);                        }                    }                }            }            catch (SocketException ex)            {               //            }        }        //处理解析数据        private void Receive(string msg, string ip)        {           //        }        #endregion        #region 关闭与退出        //窗体关闭        private void TcpServer_FormClosing(object sender, FormClosingEventArgs e)        {            if (mythread != null)            {                mythread.Interrupt();                mythread.Abort();                GC.Collect();            }        }        #endregion    }} 
 
[解决办法]
你的要求不应该和死循环挂钩，可尝试缓存依赖之类的...
[解决办法]
用定时器去做
[解决办法]
探讨
线程中
while(true)
{
}

[解决办法]
网站是不会让你控制socket的，你要想做到这效果，如果是windows操作系统的，需要开发一个后台服务程序，在服务程序里管理你自己的socket，web可以通过本地socket再跟你的服务程序通信。
[解决办法]
如果你只是要来个用户就把该拥护记录 那么你还是用 Application  来做比较好的。这个在你的网站运行期间Application 会一直存在的。Cookie 保存在用户的客户端，而 Application 保存在服务器了 会一直存在  你可以查查Application的用法。对你会有帮助的。非常建议你使用Application
[解决办法]
Socket用异步侦听
[解决办法]
是否可以尝试下quartz.net任务调度计划
[解决办法]
果断WINDOWS服务
并且每隔多少毫秒休眠一次以免CPU占用过高
[解决办法]
新线程+while(true){}，如果需要等待，就sleep线程
[解决办法]
如果是死循环，那么你自己在Global文件中Application_Begin时创建一个线程，然后把这个线程的优先级尽量的调低，这样你的死循环既可以很好的运行，也不会影响其它人访问你的网站。

[解决办法]
用TIMER吧，定时轮询，死循环是肯定不敢用的，或者多线程是必须的
[解决办法]
最好就是再写一个监控程序挂上。是循环当机了咋办。
[解决办法]
windows编程的消息机制就是一个死循环。这要求也没什么奇怪的，
换个名字就好理解了
[解决办法]
对于你的问题 可以通过观察者模式+单例模式做一个生产者，也就是25楼说的自定义事件的方法。对外广播数据变化。有新的实例需要获取你轮询的信息的时候 只需要注册相应的事件即可。

至于死循环，可以使用微软提供的任务并行机制。启用Task进行异步操作，降低性能损耗。简单例子如下。使用Task也可以通过其信号机制强制停止任务 可以达到你有一个人可以控制轮循的目的
C# code
   #region Sample        CancellationTokenSource cts = new CancellationTokenSource();//提供循环取消机制        //启动任务        public void StartLoop()        {            CancellationToken ct = cts.Token;            var loopTask = Task.Factory.StartNew(() => LoopBody(ct), ct);//启动一个任务            Task.WaitAll(loopTask);//等待任务完成        }        /制终止任务        public void StopLoop()        {            cts.Cancel();//取消当前任务        }        //任务行为        private void LoopBody(CancellationToken ct)        {            while (true)            {                //判断是否有强制退出任务的请求                if (ct.IsCancellationRequested)                {                    ct.ThrowIfCancellationRequested();                }                //TODO：你的逻辑                //在这里抛出自定义事件            }        }        #endregion
[解决办法]
using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;

namespace Test
{
   public sealed class MyTest
   {
       private static readonly MyTest _instance = new MyTest();
       private Socket _socket;
       private SocketAsyncEventArgs _asyncArgs;
       private byte[] _buffer = new byte[1024];
       private byte[] _tempbuffer;
       /// <summary>
       ///  
       /// </summary>
       private MyTest()
       { }
       /// <summary>
       /// 单例入口
       /// </summary>
       public static readonly MyTest Instance
       {
           get { return _instance; } 
 
       }
       /// <summary>
       /// 连接Socket（只调用一次）
       /// </summary>
       /// <param name="ip"></param>
       /// <param name="port"></param>
       public void Connect(string ip, int port)
       {
           this._asyncArgs = new SocketAsyncEventArgs();
           this._asyncArgs.SetBuffer(this._buffer, 0, this._buffer.Length);
           this._asyncArgs.Completed += new EventHandler<SocketAsyncEventArgs>(_asyncArgs_Completed);
           this._socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
           bool result = this._socket.ConnectAsync(this._asyncArgs);
           if (!result)
           {
             bool result1=  this._socket.ReceiveAsync(this._asyncArgs);
             if (!result1)
             {
                 this.ProcessReceive(this._asyncArgs);
             }
           }
       }
       /// <summary>
       /// Socket事件
       /// </summary>
       /// <param name="sender"></param>
       /// <param name="e"></param>
       private void _asyncArgs_Completed(object sender, SocketAsyncEventArgs e)
       {
           switch (e.LastOperation)
           {
               case SocketAsyncOperation.Receive: this.ProcessReceive(e); break;
               case SocketAsyncOperation.Connect: this.ProcessConected(e); break;
               default: break;
           }
       }
       /// <summary>
       /// 处理连接事件
       /// </summary>
       /// <param name="e"></param>
       private void ProcessConected(SocketAsyncEventArgs e)
       {
           if (e.SocketError == SocketError.Success)
           {
              bool result= this._socket.ReceiveAsync(e);
              if (!result)
              {
                  this.ProcessReceive(e);
              }
           }
       }
       /// <summary>
       /// 处理接收
       /// </summary>
       /// <param name="e"></param>
       private void ProcessReceive(SocketAsyncEventArgs e)
       {
           if (e.SocketError == SocketError.Success && e.BytesTransferred > 0)
           {
               byte[] bs = new byte[e.BytesTransferred];
               Buffer.BlockCopy(this._buffer, 0, bs, 0, bs.Length);
               this._tempbuffer = bs;
               bool result = this._socket.ReceiveAsync(e);
               if (!result)
               {
                   this.ProcessReceive(e);
               }
           }
       }
       /// <summary>
       /// 获取接收的数据
       /// </summary>
       /// <returns></returns>
       public byte[] GetData()
       {
           return this._tempbuffer;
       }
   }
}
Socket 接收死循环，楼主自己判断该判断的条件
[解决办法]
windows服务定时任务啊。。定时调用你的web服务。。。
[解决办法]
在一些行业的软件中，死循环是有必要的，例如医疗器材，金融的支持系统
[解决办法]
探讨

对于你的问题 可以通过观察者模式+单例模式做一个生产者，也就是25楼说的自定义事件的方法。对外广播数据变化。有新的实例需要获取你轮询的信息的时候 只需要注册相应的事件即可。

至于死循环，可以使用微软提供的任务并行机制。启用Task进行异步操作，降低性能损耗。简单例子如下。使用Task也可以通过其信号机制强制停止任务 可以达到你有一个人可以控制轮循的目的
C# code

   #reg……

[解决办法]
又不是Session_Start，怎么全和在线人数有关？

探讨

我是担心  同时在线人数多了后,  会造成多个实例不停的重复查询 接口

引用: 
 
引用:
当有人访问的时候去查不行么~~~~~~

没人访问。。。你在哪里，不停的查啊~~刷啊~~` 也没意义啊~~~~~

也对啊

实时的话 写个计时器
global.asax

设定了一个计时器
void Application_Start(ob……
读书人网 >asp.net

热点推荐

触屏版 | 电脑版

读书人网 m.reader8.net