事件存储连接已关闭

Question

使用以下 docker-compose 文件，我启动了我的 .Net Core 3.1 控制台应用程序和一个事件存储容器。

version: "3.4"

services:
  eventstore:
    image: eventstore/eventstore
    networks:
      - eventnet
    ports:
      - "2113:2113"
      - "1113:1113"
  consoleapp4:
    image: ${DOCKER_REGISTRY-}consoleapp4
    build:
      context: .
      dockerfile: ConsoleApp4/Dockerfile
    depends_on:
      - eventstore

networks:
  eventnet:
    driver: bridge

构建/运行 docker-compose 文件后，可以在http://localhost:2113上访问 EventStore UI ；这样一个工作。

我的控制台很简单，看起来像这样，但是连接有问题。我得到一个未处理的异常类型

System.Private.CoreLib.dll 中发生“EventStore.ClientAPI.Exceptions.ConnectionClosedException”：“Connection 'MyConName' 已关闭。”：

using System;
using EventStore.ClientAPI;
using Newtonsoft.Json;

namespace ConsoleApp4
{
    class Program
    {
        static void Main(string[] args)
        {
            var connectionSettings = ConnectionSettings.Create();
            connectionSettings.UseConsoleLogger().UseDebugLogger().EnableVerboseLogging().Build();

            var connection = EventStoreConnection.Create("ConnectTo=tcp://admin:changeit@localhost:1113", connectionSettings, "MyConName");
            connection.Connected += (a, b) =>
            {
                var x = 3; // Never comes here
            };

            connection.ErrorOccurred += (a, b) =>
            {
                var x = 5; // Never comes here
            };

            connection.ConnectAsync().Wait();
            var model = new MyModel();
            var item = new EventData(model.Id, model.GetTypeString(), true, model.GetByteArray(), new byte[] { });

            // Throws exception 'EventStore.ClientAPI.Exceptions.ConnectionClosedException'
            var result = connection.AppendToStreamAsync("mystream", 0, item).GetAwaiter().GetResult();
        }
    }

    class MyModel
    {
        public Guid Id { get; } = Guid.NewGuid();

        public string GetTypeString() => this.GetType().FullName.ToLower();

        public byte[] GetByteArray() => System.Text.Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(this));
    }
}

我完全不知道该做什么了，所以任何指针都会受到高度赞赏，它一定是简单的东西吧..？

我试过另一台机器，全新开始，尝试使用 IP 地址，另一种设置连接字符串的方法，Powershell 告诉我：

C:\WINDOWS\system32> Test-NetConnection -ComputerName localhost -Port 1113


ComputerName     : localhost
RemoteAddress    : ::1
RemotePort       : 1113
InterfaceAlias   : Loopback Pseudo-Interface 1
SourceAddress    : ::1
TcpTestSucceeded : True

---

编辑

将我的 docker-compose 文件更改为：

C:\WINDOWS\system32> Test-NetConnection -ComputerName localhost -Port 1113


ComputerName     : localhost
RemoteAddress    : ::1
RemotePort       : 1113
InterfaceAlias   : Loopback Pseudo-Interface 1
SourceAddress    : ::1
TcpTestSucceeded : True

或者

version: '3.4'

services:
  myeventstore:
    image: eventstore/eventstore
    ports:
      - "2113:2113"
      - "1113:1113"
  console:
    image: ${DOCKER_REGISTRY-}console
    build:
      context: .
      dockerfile: Console/Dockerfile
    depends_on:
      - myeventstore

和连接字符串：myeventstore仍然没有成功......

Answer 1

尽管事实上我无法像主要要求的那样让这个东西工作，但我确实设法通过 SSL 让事情工作；带有自签名证书。

用于创建自签名证书的 Dockerfile，用于开发环境：

FROM eventstore/eventstore
RUN apt-get update -y \
  && apt-get install -y openssl \
  && openssl req -x509 -sha256 -nodes -days 3650 -subj "/CN=eventstore.org" -newkey rsa:2048 -keyout eventstore.pem -out eventstore.csr \
  && openssl pkcs12 -export -inkey eventstore.pem -in eventstore.csr -out eventstore.p12 -passout pass: \
  && openssl pkcs12 -export -inkey eventstore.pem -in eventstore.csr -out eventstore.pfx -passout pass: \
  && mkdir -p /usr/local/share/ca-certificates \
  && cp eventstore.csr /usr/local/share/ca-certificates/eventstore.crt \
  && update-ca-certificates \
  && apt-get autoremove \
  && apt-get clean \
  && rm -rf /var/lib/apt/lists/* /tmp/* /var/tmp/*

我的 docker-compose 文件如下所示：

version: '3.4'

services:
  myeventstore:
    image: eventstore/eventstore:with-cert-local
    build:
      context: .
      dockerfile: .docker/EventStore/Dockerfile
    ports:
      - "2113:2113"
      - "1113:1113"
      - "1115:1115"
    environment:
      - EVENTSTORE_CERTIFICATE_FILE=eventstore.p12 
      - EVENTSTORE_EXT_SECURE_TCP_PORT=1115 

  console:
    image: ${DOCKER_REGISTRY-}console
    build:
      context: .
      dockerfile: Console/Dockerfile
    depends_on:
      - myeventstore

using System;
using System.Text;
using System.Threading.Tasks;
using EventStore.ClientAPI;
using Newtonsoft.Json;

namespace Console
{
    internal static class Program
    {
        private static async Task Main()
        {
            var connectionSettings = ConnectionSettings.Create();
            connectionSettings.EnableVerboseLogging()
                .UseDebugLogger()
                .UseConsoleLogger()
                .SetHeartbeatTimeout(TimeSpan.FromSeconds(60))
                .SetHeartbeatInterval(TimeSpan.FromSeconds(30));

            var connection = EventStoreConnection.Create(
                "ConnectTo=tcp://myeventstore:1115;DefaultUserCredentials=admin:changeit;UseSslConnection=true;TargetHost=eventstore.org;ValidateServer=false",
                connectionSettings, "MyConName");

            await connection.ConnectAsync();

            var model = new MyModel();
            var item = new EventData(model.Id, model.GetTypeString(), true, model.GetByteArray(), new byte[] { });

            var result = await connection.AppendToStreamAsync("mystream", ExpectedVersion.Any, item);
        }
    }

    public class MyModel : MyBaseEvent, IEventId
    {
        /// <inheritdoc />
        public Guid Id { get; } = Guid.NewGuid();
    }

    public abstract class MyBaseEvent
    {
        public string GetTypeString() => GetType().ToString().ToLower();

        public byte[] GetByteArray() => Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(this));
    }

    public interface IEventId
    {
        Guid Id { get; }
    }
}