草庐IT

go - 如何从Windows服务运行另一个可执行文件

coder 2024-07-06 原文

除了关于Go的一些教程之外,我没有实际经验。我正在尝试采用Go语言编写的项目,并将其转换为Windows服务。

老实说,我除了尝试找到可以阅读的东西外,没有尝试过其他任何东西。我找到了一些线程,并选择了我认为可以满足我们所有需求的最佳库

https://github.com/golang/sys

// Copyright 2012 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// +build windows

package main

import (
    "fmt"
    "strings"
    "time"

    "golang.org/x/sys/windows/svc"
    "golang.org/x/sys/windows/svc/debug"
    "golang.org/x/sys/windows/svc/eventlog"
)

var elog debug.Log

type myservice struct{}

func (m *myservice) Execute(args []string, r <-chan svc.ChangeRequest, changes chan<- svc.Status) (ssec bool, errno uint32) {
    const cmdsAccepted = svc.AcceptStop | svc.AcceptShutdown | svc.AcceptPauseAndContinue
    changes <- svc.Status{State: svc.StartPending}
    fasttick := time.Tick(500 * time.Millisecond)
    slowtick := time.Tick(2 * time.Second)
    tick := fasttick
    changes <- svc.Status{State: svc.Running, Accepts: cmdsAccepted}
loop:
    for {
        select {
        case <-tick:
            beep()
            elog.Info(1, "beep")
        case c := <-r:
            switch c.Cmd {
            case svc.Interrogate:
                changes <- c.CurrentStatus
                // Testing deadlock from https://code.google.com/p/winsvc/issues/detail?id=4
                time.Sleep(100 * time.Millisecond)
                changes <- c.CurrentStatus
            case svc.Stop, svc.Shutdown:
                // golang.org/x/sys/windows/svc.TestExample is verifying this output.
                testOutput := strings.Join(args, "-")
                testOutput += fmt.Sprintf("-%d", c.Context)
                elog.Info(1, testOutput)
                break loop
            case svc.Pause:
                changes <- svc.Status{State: svc.Paused, Accepts: cmdsAccepted}
                tick = slowtick
            case svc.Continue:
                changes <- svc.Status{State: svc.Running, Accepts: cmdsAccepted}
                tick = fasttick
            default:
                elog.Error(1, fmt.Sprintf("unexpected control request #%d", c))
            }
        }
    }
    changes <- svc.Status{State: svc.StopPending}
    return
}

func runService(name string, isDebug bool) {
    var err error
    if isDebug {
        elog = debug.New(name)
    } else {
        elog, err = eventlog.Open(name)
        if err != nil {
            return
        }
    }
    defer elog.Close()

    elog.Info(1, fmt.Sprintf("starting %s service", name))
    run := svc.Run
    if isDebug {
        run = debug.Run
    }
    err = run(name, &myservice{})
    if err != nil {
        elog.Error(1, fmt.Sprintf("%s service failed: %v", name, err))
        return
    }
    elog.Info(1, fmt.Sprintf("%s service stopped", name))
}

所以我花了一些时间来研究这段代码。测试了一下,看看它能做什么。它执行应有的功能。

我的问题是我们目前有一个Go程序,该程序接受参数,对于我们的服务,我们将其传递给服务器。这使我们的内容在本地主机网页上旋转。

我相信上面的代码可能与此有关,但是我迷失了如何正确地将它从我们的exe文件中剥离出来。这是打电话给Main的合适地点吗?

很抱歉,如果这含糊。我不知道该如何与已经存在的exe进行交互。

如果我知道需要更改的内容,则可以进行修改。我感谢您的帮助。

最佳答案

好吧,现在更清楚了。好吧,理想情况下,您应该从一些有关Windows服务的组成的教程开始-我打赌这可能为您解决了这个问题。但是我们还是尝试一下。

一些理论

Windows服务的种类有两个方面:它执行一些有用的任务,并与SCM facility通信。当您使用sc命令或通过“控制面板”操作服务时,您具有代表您与SCM进行对话的软件,并且SCM与该服务进行对话。

SCM和服务使用的确切协议是底层且复杂的
而您使用的Go软件包的目的是向您隐藏这种复杂性
并为这些内容提供合理的以Go为中心的界面。

正如您可能从自己的示例中收集的那样,您创建的类型的Execute方法在大多数情况下与与SCM通讯有关:它运行一个无穷的for循环,每次循环都在从r通道读取时休眠,并且该渠道将SCM命令传递给您的服务。

因此,您基本上有了所谓的“SCM命令处理循环”。

现在回想一下上面的两个方面。您已经拥有其中之一:您的服务与SCM进行交互,因此您需要另一个-实际上执行有用任务的代码。

实际上,它已经部分存在:您抓取的示例代码创建了一个时间行情记录器,该行情记录器提供了一个通道,当另一个滴答经过时,该通道可在该通道上传递值。 for方法中的Execute循环也从该通道读取,每次发出另一个滴答声时都在“工作”。

好的,这对于玩具示例来说很好,但对于实际工作却很la脚。

接近解决方案

因此,让我们暂停片刻,思考一下我们的要求。

  • 我们需要一些代码来运行并完成我们的实际任务。
  • 我们需要现有的命令处理循环才能继续工作。
  • 我们需要这两段代码来同时工作。

  • 在这个玩具示例中,第3点是“免费的”,因为时间行情记录器会自动与其他代码完全并发地等待下一个行情记录。

    您的实际代码很可能不会那么奢侈,那么您该怎么办?

    在Go中,当您需要同时进行其他操作时,
    一个明显的答案是“使用goroutine”。

    因此,第一步是获取您现有的代码,将其转换为可调用的函数
    然后在进入for循环之前,在单独的goroutine中调用它。
    这样,您将同时运行两个部分。

    困难的部分

    好,那不难。

    困难的部分是:
  • 如何配置执行任务的代码。
  • 如何使SCM命令处理循环与执行任务的代码通信。

  • 组态

    这确实取决于您$ dayjob或$ current_project的策略,但是有一些提示:
  • Windows服务可能会收到命令行参数,无论是一次运行还是永久性(每次运行都传递给该服务)。

    不利的一面是从UI / UX的角度来看,使用它们并不方便。
  • 通常,Windows服务用于读取注册表。
  • 这些天(在.NET及其普遍的xml-ity出现之后),服务倾向于读取配置文件。
  • 大多数情况下,OS环境都不适合该任务。
  • 您可以合并其中几个场所。

  • 我想我应该从配置文件开始,但是我想再选择一次阻力最小的路径。

    要记住的一件事是,最好在服务向SCM发送启动信号之前就对配置进行读取和处理,好:如果配置无效或无法加载,则服务应广泛记录并发出信号失败,并且没有运行实际的任务处理代码。

    命令处理循环与带有代码的任务之间的通信

    这是IMO最困难的部分。

    可以在这里写整本书,但现在让我们保持简单。

    为了使其尽可能简单,我将执行以下操作:
  • 考虑暂停,停止和关闭几乎相同:所有这些信号必须告诉您的任务处理代码退出,然后等待它实际执行。
  • 认为“继续”信号与启动任务处理功能相同:在新的goroutine中再次运行它。
  • 进行单向通信:从控制循环到任务处理代码,而没有其他方法-这将大大简化服务状态管理。

  • 这样,您可以创建一个通道,任务处理代码会侦听该通道或定期检查该通道,并且当某个值来自该通道时,该代码将停止运行,关闭该通道并退出。

    当SCM告诉它暂停,停止或关闭时,控制回路会在该通道上发送任何内容,然后等待其关闭。发生这种情况时,它知道任务处理代码已完成。

    在Go中,仅用于信令的通道的范例是具有struct{}类型(空struct)的通道。

    如何在运行代码的任务中监视此控制通道的问题是一个开放的问题,并且在很大程度上取决于它执行的任务的性质。

    此处的任何其他帮助都将引用Go并发书籍中的内容,因此您应该首先介绍它。

    还有一个有趣的问题,就是如何使控制回路与任务处理回路之间的通信具有弹性,以应对后者中可能发生的处理停顿,但是话又说回来,IMO还为时过早。

    关于go - 如何从Windows服务运行另一个可执行文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57513386/

    有关go - 如何从Windows服务运行另一个可执行文件的更多相关文章

    1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

      我正在学习如何使用Nokogiri,根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

    2. ruby - 如何从 ruby​​ 中的字符串运行任意对象方法? - 2

      总的来说,我对ruby​​还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用

    3. ruby - 使用 RubyZip 生成 ZIP 文件时设置压缩级别 - 2

      我有一个Ruby程序,它使用rubyzip压缩XML文件的目录树。gem。我的问题是文件开始变得很重,我想提高压缩级别,因为压缩时间不是问题。我在rubyzipdocumentation中找不到一种为创建的ZIP文件指定压缩级别的方法。有人知道如何更改此设置吗?是否有另一个允许指定压缩级别的Ruby库? 最佳答案 这是我通过查看ruby​​zip内部创建的代码。level=Zlib::BEST_COMPRESSIONZip::ZipOutputStream.open(zip_file)do|zip|Dir.glob("**/*")d

    4. ruby - 其他文件中的 Rake 任务 - 2

      我试图在一个项目中使用rake,如果我把所有东西都放到Rakefile中,它会很大并且很难读取/找到东西,所以我试着将每个命名空间放在lib/rake中它自己的文件中,我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题,但没有任务。我现在只有一个.rake文件作为测试,名为“servers.rake”,它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

    5. ruby-on-rails - 在 Rails 中将文件大小字符串转换为等效千字节 - 2

      我的目标是转换表单输入,例如“100兆字节”或“1GB”,并将其转换为我可以存储在数据库中的文件大小(以千字节为单位)。目前,我有这个:defquota_convert@regex=/([0-9]+)(.*)s/@sizes=%w{kilobytemegabytegigabyte}m=self.quota.match(@regex)if@sizes.include?m[2]eval("self.quota=#{m[1]}.#{m[2]}")endend这有效,但前提是输入是倍数(“gigabytes”,而不是“gigabyte”)并且由于使用了eval看起来疯狂不安全。所以,功能正常,

    6. ruby - 在 Ruby 程序执行时阻止 Windows 7 PC 进入休眠状态 - 2

      我需要在客户计算机上运行Ruby应用程序。通常需要几天才能完成(复制大备份文件)。问题是如果启用sleep,它会中断应用程序。否则,计算机将持续运行数周,直到我下次访问为止。有什么方法可以防止执行期间休眠并让Windows在执行后休眠吗?欢迎任何疯狂的想法;-) 最佳答案 Here建议使用SetThreadExecutionStateWinAPI函数,使应用程序能够通知系统它正在使用中,从而防止系统在应用程序运行时进入休眠状态或关闭显示。像这样的东西:require'Win32API'ES_AWAYMODE_REQUIRED=0x0

    7. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

      关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

    8. ruby-on-rails - Rails 3 中的多个路由文件 - 2

      Rails2.3可以选择随时使用RouteSet#add_configuration_file添加更多路由。是否可以在Rails3项目中做同样的事情? 最佳答案 在config/application.rb中:config.paths.config.routes在Rails3.2(也可能是Rails3.1)中,使用:config.paths["config/routes"] 关于ruby-on-rails-Rails3中的多个路由文件,我们在StackOverflow上找到一个类似的问题

    9. ruby-on-rails - 如何验证 update_all 是否实际在 Rails 中更新 - 2

      给定这段代码defcreate@upgrades=User.update_all(["role=?","upgraded"],:id=>params[:upgrade])redirect_toadmin_upgrades_path,:notice=>"Successfullyupgradeduser."end我如何在该操作中实际验证它们是否已保存或未重定向到适当的页面和消息? 最佳答案 在Rails3中,update_all不返回任何有意义的信息,除了已更新的记录数(这可能取决于您的DBMS是否返回该信息)。http://ar.ru

    10. ruby-openid:执行发现时未设置@socket - 2

      我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时,我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb,在下面的代码片段中:moduleNetclass

    随机推荐