没有 Rabbit MQ 连接的 Docker 容器内的 Elixir 版本

Question

我对 Elixir 很陌生。我已经构建了一个在本地运行的应用程序，效果很好。但现在我需要用 Docker 为它构建一个容器。

但是，每次发布的尝试似乎都是尝试连接到 RabbitMQ（在本地运行，作为 Docker 容器）。

我不希望，不能在每次构建此容器时尝试连接到 Rabbit，因为它需要由 CI / CD 管道构建，并且永远无法访问任何 Rabbit。我已经使用 ENV 对其进行了设置，但是在部署到我的 k8s 集群时需要在我的 YAML 中进行设置。

这就是 Dockerfile：

# Container Base Image
FROM elixir:1.13.1-alpine as release_build

# Set Working Folder
WORKDIR app

#ENV RABBIT_CONNECTION=""

# Copy Source Code Into Container
COPY ./src/app ./

# Install Hex Package Manager
RUN mix local.hex --force

# Install Rebar
RUN mix local.rebar --force

# Get All Deps
RUN mix deps.get

RUN mix deps.compile

# Compile Application
RUN mix compile

那么您是否可以看到我设置了带有 Rabbit 连接 URL 的 ENV（当前已注释掉）。在这种状态下，我得到，

The following arguments were given to AMQP.Connection.open/1:

如果我设置它，但只设置为一个空字符串，我会得到，

no match of right hand side value: {:error, {{:unable_to_parse_uri, :no_scheme}, []}}

我也尝试使用本地运行的容器的有效 URL，但它是否使用 localhost 和不同的 Docker 网络，这只是返回了 econnrefused 错误。

这就是我在我的应用中连接到 Rabbit 的方式，

rabbit_url = Application.fetch_env!(:rabbit, :url)

# Open Connection To Rabbit
{:ok, connection} = AMQP.Connection.open(rabbit_url)
{:ok, channel} = AMQP.Channel.open(connection)

这是兔子配置文件部分，

配置：兔子， url: System.get_env("RABBIT_CONNECTION")

我制作了一个小的本地 Bash 脚本来启动它，

RABBIT_CONNECTION='amqp://admin:password@localhost:5672' iex -S mix

这个脚本可以很好地与应用程序一起启动并连接到我本地运行的 RabbitMQ 容器

所以我知道必须有一种方法可以让代码在没有连接的情况下进行发布，无论是到 Rabbit 还是数据库或类似的东西。

欢迎任何帮助

谢谢，

Answer 1

我已经尝试过创建一个像你这样的项目。

mix new broker_client

在mix.exs应用函数中配置运行我的模块的启动函数。

def application do
  [
    extra_applications: [:logger],
    mod: {BrokerClient, []}
  ]
end

另外，在 config/runtime.exs 中，我将 amqp 配置为连接和一个或多个通道为 documented here。

import Config

config :amqp,
  connections: [
    myconn: [url: System.get_env("BROKER_URL")]
  ],
  channels: [
    mychan: [connection: :myconn]
  ]

在 lib/broker_client.ex 中，我实现了启动函数，它创建了一个简单的任务，如 this answer 所示。

defmodule BrokerClient do
  def sample() do
    {:ok, chan} = AMQP.Application.get_channel(:mychan)
    :ok = AMQP.Basic.publish(chan, "", "", "Hello")
    Process.sleep(1000 * 10)
  end

  def start(_type, _args) do
    IO.puts("starting...")
    Task.start(fn -> sample() end)
  end
end

无需在本地运行 rabbitmq 或设置变量代理，我就可以很好地构建它。

FROM elixir as builder
WORKDIR /app
RUN mix local.hex --force && mix local.rebar --force
COPY mix.exs mix.lock ./
RUN mix deps.get --only prod
COPY  ./ .
RUN MIX_ENV=prod mix release

FROM debian:stable-slim
ENV LANG="C.UTF-8" LC_AL="C.UTF-8" PATH="/app/bin:$PATH"
COPY --from=builder /app/_build/prod/rel/broker_client /app
CMD [ "broker_client", "start"]

现在我可以以 docker-compose 为例来运行它。

version: '3.9'

services:
  client:
    build: ./
    environment:
      BROKER_URL: 'amqp://guest:guest@rabbitmq'
    # sleep 10 seconds to give the broker time to start
    command: [ "sh", "-c", "sleep 10 && broker_client start" ]
    depends_on:
      - rabbitmq
  rabbitmq:
    image: rabbitmq

查看Application 的官方文档可能也很有用。

Answer 2

您需要使用runtime 配置，否则必须在编译时传递配置，为此您只需添加runtime.exs 并在那里获取环境变量：

config :rabbit, url: System.get_env("RABBIT_CONNECTION")