docker - 没有 Rabbit MQ Connection 的 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，但它是否使用本地主机并在不同的 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)

这是兔子配置文件部分，

配置:兔子，网址: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 配置为连接和一个或多个 channel 为 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 在本地运行或设置变量 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 的官方文档可能也很有用.