c# - 事件存储连接已关闭

Question

使用以下docker-compose文件，启动.Net Core 3.1 Console应用程序和事件存储容器。

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；这样一个作品。

我的控制台非常简单，看起来像这样，但是连接时遇到了麻烦。我收到一个未处理的类型异常

'EventStore.ClientAPI.Exceptions.ConnectionClosedException' occurred in System.Private.CoreLib.dll: 'Connection 'MyConName' was closed.':

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文件更改为:

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

或者

version: '3.4'

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

networks:
  eventsnet:
    driver: bridge

和连接字符串到: 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; }
    }
}