没有 Rabbit MQ 连接的 Docker 容器内的 Elixir 发布

Elixir release inside Docker container without Rabbit MQ Connection

我是 Elixir 的新手。我构建了一个在本地运行的应用程序,运行良好。但是现在我需要用 Docker.

为它构建一个容器

但是,每次尝试发布似乎都会尝试连接到 RabbitMQ(在本地 运行,作为 Docker 容器)。

我不想,不能让它在每次构建这个容器时尝试连接到 Rabbit,因为它将需要通过 CI / CD 管道构建并且永远无法访问任何兔子。我已经用 ENV 设置了它,但这需要在部署到我的 k8s 集群时在我的 YAML 中设置。

所以这是 Docker 文件:

# 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 Connection 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,但它是否使用本地主机并在不同的 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 还是数据库或类似的东西。

欢迎任何帮助

谢谢,

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

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 中,我实现了启动函数,它创建了一个简单的任务,如 .

中所示
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 运行ning 或设置变量 broker 的情况下构建它。

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 的官方文档可能也很有用。

你需要使用runtime配置,否则配置必须在编译时传递,为此你所要做的就是添加runtime.exs并在那里获取环境变量:

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