在服务器上运行多个操作

Question

在我们的网站上，我们的版主可以查看人们发布的内容。这也适用于视频，尽管需要先转换视频。这要么在晚上自动发生（通过 Windows 服务），要么在主持人手动启动时更早发生。

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

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

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

1. 是否可以运行一项服务的多个实例？
2. 我可以让服务更有活力吗？例如，如果主持人 #2 启动转换，它将启动服务，但如果服务已经启动，是否可以将文件添加到列表中？ （在服务启动时，我创建了一个列表，该列表从数据库中读取每个文件以查找单个转换标志）
3. 我知道我一直在考虑服务，是否有另一种方法来处理服务器上的操作，可以处理版主的多个请求？

我知道这听起来可能有点模糊，所以如果您有任何问题，请尽管提问。

编辑：也许我应该提供一些额外的信息，目前我是一名正在实习的学生，我的发起人并不想几乎立即转换文件。他们希望在晚上进行转换，除非版主为单个文件手动启动它。此外，网站和文件系统位于同一台服务器上（数据库位于单独的服务器上）。基本上，工作将在网站运行所在的同一台服务器上完成（目前无法分离）。他们担心服务器的性能。

任何评论将不胜感激！ 亲切的问候， 弗洛里斯

Answer 1

IMO 处理此问题的明智方法是使用任何形式的队列。一个简单的数据库表（或 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
         }
      }