在服务器上运行多个操作

Question

在我们的网站上，我们的版主可能会审阅用户发布的内容。这也适用于视频，但视频需要先转换。这可以在夜间自动发生（通过Windows服务），也可以在主持人手动启动时立即发生。

现在，这最后一部分是我的问题来自何处。起初我以为我只是写一个单独的服务来处理转换。无论何时主持人开始转换，数据库中的记录都会更新以将其标记为单次转换。然后服务将处理剩下的事情。当它只是一个文件时，这一切都很好。

但想象一下这种情况，主持人＃1启动服务。该服务运行并启动文件转换。在该过程中，主持人＃2开始转换不同的文件。它会尝试启动服务，但因为它已经启动而失败。该文件将被标记为单独转换，但不会转换，因为它无法启动服务。

现在我正在寻找新的想法来解决这个问题。

1. 是否可以运行一个服务的多个实例？
2. 我可以使服务更具动态性吗？例如，如果版主＃2开始转换，它将启动服务，但是如果服务已经启动，是否可以将文件添加到列表中？ （在服务开始时，我创建一个列表，从数据库中读取每个文件，寻找单个转换标志）
3. 我知道我一直在想服务，是否有另一种方式来处理服务器上的操作可以处理版主的多个请求？

我意识到它可能听起来有点模糊，所以如果你有任何问题请问。也许我应该提供一些额外的信息，目前我是一名在实习中工作的学生，我的发起人并不真的想要一个文件几乎立即转换。他们希望在晚上进行转换，除非主持人手动为单个文件启动转换。此外，网站和文件系统位于同一台服务器上（数据库位于单独的服务器上）。基本上，这些工作将在网站运行的同一台服务器上完成（它目前不能分开）。他们担心服务器的性能。

如有任何意见，将不胜感激！ 各种问候， 弗洛里斯

Answer 1

国际海事组织的理智的方式来处理这是任何形式的队列。一个简单的数据库表（或一个redis列表）就足够了。你的服务应该简单地检查：有工作要做吗？我会这样做：做，否则睡一会儿，然后重新查询。作为一个可选的额外的东西，像pub/sub这样的东西可以用于更快的唤醒，所以在入队和出队之间没有可察觉的延迟 - 但理想情况下，队列/轮询循环应该没有额外的工作。

然后，批处理过程很简单：将工作添加到队列中。或者，您可能会优先考虑，以便主持人（或其他“现场”用户）在进行后台处理之前获得工作。

它是可能多次运行同一个exe作为服务（给它不同的服务名称），但每个都需要显式设置。说实话，在你的情况下它是不值得的：一个更简单的选择是让多个工作线程服务队列，这可以在一个进程中完成。

Answer 2

我会删除主持人手动启动服务的选项（只是我的首选项），并启动一个线程轮询您的数据库以查找需要转换的文件。

如果你有服务中的代码，你可以在下面的函数中运行它。如果不是，则将该函数保留在单个线程下方，然后以编程方式在该函数内启动该服务以执行转换。这个问题的答案可以根据您是否拥有服务代码并可以进行更改而发生重大变化。如果您可以修改它，您可以将相同类型的逻辑放入服务中。

在你的Global.asax.cs的Application_Start事件，我将开始一个新的线程不断循环并检查你的数据库

using System.Threading; 


    void Application_Start(object sender, EventArgs e)   
    { 
     Thread VideoConversionThread = new System.Threading.Thread(new ThreadStart(VideoConversion)); 
     VideoConversionThread.Name = "VideoConversion"; 
     VideoConversionThread.IsBackground = true; 
     VideoConversionThread.Start(); 
    } 
    private void VideoConversion() 
    { 
     while (true) 
     { 
      //Get Count of records that need conversion. 
      if(Count > 0) 
      { 
       var records = //GetRecords from database that require conversion 
       foreach(var record in records) 
       { 
        //either spawn a seperate worker thread for each record or perform tasks here 

        //perform conversion 
        //update database to mark item as completed 
        // or 
        //in this single thread, you could also start the service 
        //(does the service Stop when it's finished?) 
        //(if so, you can monitor and wait for it to be stopped for each record) 
       } 
      } 
      Thread.Sleep(5000); //sleep 
     } 
     }