2017-04-14 73 views
2

我试图实现类似于this answer中描述的内容,但是当我编译应用程序时,出现如下所示的错误。监督树未能启动

** (Mix) Could not start application workers: Workers.Application.start(:normal, []) returned an error: shutdown: failed to start child: {Workers.UrlSupervisor, 2} 
    ** (EXIT) already started: #PID<0.1034.0> 

我不确定我是否内在地做某件事情,我不允许在这里,或者我犯了一个小错误。

对于这里有些方面是主管:

defmodule Workers.Application do 
    # See http://elixir-lang.org/docs/stable/elixir/Application.html 
    # for more information on OTP Applications 
    @moduledoc false 

    use Application 

    def start(_type, _args) do 
    import Supervisor.Spec, warn: false 

    url_workers = 1..100 |> Enum.map(fn (i) -> supervisor(Workers.UrlSupervisor, [i], [id: {Workers.UrlSupervisor, i}, restart: :temporary]) end) 
    domain_workers = 1..100 |> Enum.map(fn (i) -> supervisor(Workers.DomainSupervisor, [i], [id: {Workers.DomainSupervisor, i}, restart: :temporary]) end) 

    opts = [strategy: :one_for_one, name: Workers.Supervisor] 
    Supervisor.start_link(url_workers ++ domain_workers, opts) 
    end 
end 

defmodule Workers.UrlSupervisor do 
    def start_link(id) do 
    import Supervisor.Spec, warn: false 

    children = [worker(Task, [&Workers.Url.worker/0], [id: {Workers.Url, id}, restart: :permanent])] 

    opts = [strategy: :one_for_one, name: Workers.UrlSupervisor] 
    Supervisor.start_link(children, opts) 
    end 
end 

defmodule Workers.DomainSupervisor do 
    def start_link(id) do 
    import Supervisor.Spec, warn: false 

    children = [worker(Task, [&Workers.Domain.worker/0], [id: {Workers.Domain, id}, restart: :permanent])] 

    opts = [strategy: :one_for_one, name: Workers.DomainSupervisor] 
    Supervisor.start_link(children, opts) 
    end 
end 

这里是一个工人(他们看起来大致相同)。

defmodule Workers.Domain do 
    def worker do 
    case Store.Domains.pop do 
     :empty -> 
     IO.puts "[Domain] none found, waiting..." 
     :timer.sleep(1000) 
     {crawl_id, domain} -> 
     IO.puts "[Domains] found a domain to check: #{domain}" 
     case Core.check_domain(domain) do 
      :error -> 
      Utils.insert(crawl_id, domain, false) 
      :registered -> 
      Utils.insert(crawl_id, domain, false) 
      :available -> 
      Utils.insert(crawl_id, domain, true) 
     end 
    end 
    worker() 
    end 
end 
+3

在你的'Workers.Application',开始的时候'Supervisor's,您提供独特'id's,但他们也应该有独特的名。你能否尝试添加另一个关键字,比如'name::“url_supervisor _#{i}”',以及域管理员的类似事情? –

+0

完全解决了它,我的愚蠢错误!如果你把这个做成一个答案,我会接受它:) – Zen

+1

完成。乐意效劳! –

回答

2

在你Workers.Application启动时Supervisor S,找你提供独特id S中,但也应该有独特的name秒。

尝试增加另一个关键字,像名称::"url_supervisor_#{i}"

def start(_type, _args) do 
    import Supervisor.Spec, warn: false 

    url_workers = 1..100 |> Enum.map(fn (i) -> 
    supervisor(Workers.UrlSupervisor, [i], 
       [id: {Workers.UrlSupervisor, i}, 
       name: :"url_supervisor_#{i}", # Name added here 
       restart: :temporary]) 
    end) 
    domain_workers = 1..100 |> Enum.map(fn (i) -> 
    supervisor(Workers.DomainSupervisor, [i], 
       [id: {Workers.DomainSupervisor, i}, 
       name: :"domain_supervisor_#{i}", # Name added here 
       restart: :temporary]) 
    end) 

    opts = [strategy: :one_for_one, name: Workers.Supervisor] 
    Supervisor.start_link(url_workers ++ domain_workers, opts) 
end