2

在这个上我的头撞墙了一段时间。

我正在尝试设置一个 quickfix 启动器来建立与 Bloomberg FIX 服务器的 SSL 连接。根据文档，我认为这将是相对简单的实现。但是，我似乎无法弄清楚我要去哪里错了。任何帮助将不胜感激。

注意事项：

  • 我正在使用dotnet cli创建、构建和运行项目
  • 彭博为我们提供了 3 种格式的证书：JKS、PEM 和 PKCS12
  • 我已经使用此 S/O 注释 (Convert PFX to CER)mycerts.cer中描述的过程从提供的 PKCS12 证书生成了结果文件。但是，无论是否执行此步骤，错误消息都是相同的
  • 还可能值得注意的是，我之前已经设法使用 python 版本的 quickfix 和 stunnel（处理 SSL 连接）建立和维护与bloomberg FIX 服务器的安全连接。但是我现在需要删除对 stunnel 的依赖，因此尝试切换到 quickfix/n

设置：

这是当前.csproj文件

<Project Sdk="Microsoft.NET.Sdk">

  <ItemGroup>
    <ProjectReference Include="..\Heimdall.AppTest\Heimdall.AppTest.csproj" />
  </ItemGroup>

  <ItemGroup>
    <PackageReference Include="QuickFIXn.Core" Version="1.10.0" />
    <PackageReference Include="QuickFIXn.FIX4.4" Version="1.10.0" />
  </ItemGroup>

  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>netcoreapp3.1</TargetFramework>
  </PropertyGroup>

  <Target Name="PostBuild" AfterTargets="PostBuildEvent">
    <Copy SourceFiles=".\FIX44.xml" DestinationFolder="$(TargetDir)" />
    <Copy SourceFiles=".\bbgEtomsClient.cfg" DestinationFolder="$(TargetDir)" />
    <Copy SourceFiles=".\pkcs12\cert.pfx" DestinationFolder="$(TargetDir)" />
    <Copy SourceFiles=".\openssl\mycerts.cer" DestinationFolder="$(TargetDir)" />
  </Target>

</Project>

这是启动器应用程序使用的实际bbgEtomsClient.cfg文件（基于此问题）

[DEFAULT]
ApplicationID=client
ConnectionType=initiator
HeartBtInt=60
ResetOnLogon=N
ResetSeqNumFlag=N
FileStorePath=incoming
FileLogPath=outgoing
ScreenLogShowIncoming=Y
ScreenLogShowOutgoing=Y
ScreenLogShowEvents=Y
UseDataDictionary=Y
DataDictionary=FIX44.xml
SocketConnectPort=xxxx
SocketConnectHost=xxx.xx.xxx.xx (same as SSLServerName)
SSLEnable=Y
SSLProtocols=Tls12
SSLCheckCertificateRevocation=N
SSLValidateCertificates=N
SSLServerName=xxx.xx.xxx.xx
SSLCertificate=cert.pfx
SSLCertificatePassword=<PfxCertPassword>
SSLCACertificate=mycerts.cer

[SESSION]
BeginString=FIX.4.4
SenderCompID=<SenderCompID>
TargetCompID=<TargetCompID>
StartTime=00:00:01
EndTime=23:59:59

这是超级基本的program.cs

using System;
using System.Collections.Generic;
using System.Text;
using QuickFix;
using QuickFix.Fields;
using QuickFix.Transport;
using System.Linq;

namespace Heimdall.App
{
    public class MyQuickFixApp : IApplication
    {
        public void FromApp(Message msg, SessionID sessionID) 
        {
            Console.WriteLine("IN:<FromApp>  " + msg); 
        }
        public void OnCreate(SessionID sessionID) { }
        public void OnLogout(SessionID sessionID) { }
        public void OnLogon(SessionID sessionID) { }
        public void FromAdmin(Message msg, SessionID sessionID) 
        {
            Console.WriteLine("IN:<FromAdmin>  " + msg); 
        }
        public void ToAdmin(Message msg, SessionID sessionID) 
        {
            Console.WriteLine("OUT:<ToAdmin>  " + msg); 
        }
        public void ToApp(Message msg, SessionID sessionID) 
        {
            Console.WriteLine("IN:<ToApp>  " + msg); 
        }
    }

    class Program
    {
        static void Main(string[] args)
        {
            SessionSettings settings = new SessionSettings("bbgEtomsClient.cfg");
            IApplication myApp = new MyQuickFixApp();
            IMessageStoreFactory storeFactory = new FileStoreFactory(settings);
            ILogFactory logFactory = new FileLogFactory(settings);
            SocketInitiator initiator = new SocketInitiator(
                myApp,
                storeFactory,
                settings,
                logFactory);

            try
            {


                initiator.Start();
                while (true)
                {
                    System.Threading.Thread.Sleep(2000);
                }
                

            }
            catch (System.Exception e)
            {
                Console.WriteLine("==FATAL ERROR==");
                Console.WriteLine(e.ToString());
                initiator.Stop();
            }

        }
    }
}

错误：

当使用上面列出的设置运行项目时，会观察到以下错误：

20210107-13:23:00.242 : Unexpected exception: System.ArgumentNullException: Value cannot be null. (Parameter 'value')
   at System.Collections.CollectionBase.OnValidate(Object value)
   at System.Security.Cryptography.X509Certificates.X509CertificateCollection.OnValidate(Object value)
   at System.Collections.CollectionBase.System.Collections.IList.Add(Object value)
   at System.Security.Cryptography.X509Certificates.X509CertificateCollection.Add(X509Certificate value)
   at QuickFix.Transport.StreamFactory.SSLStreamFactory.GetClientCertificates()
   at QuickFix.Transport.StreamFactory.SSLStreamFactory.CreateClientStreamAndAuthenticate(Stream innerStream)
   at QuickFix.Transport.StreamFactory.CreateClientStream(IPEndPoint endpoint, SocketSettings settings, ILog logger)
   at QuickFix.SocketInitiatorThread.SetupStream()
   at QuickFix.Transport.SocketInitiator.SocketInitiatorThreadStart(Object socketInitiatorThread)

据我所知，我的错误可能与此问题有关（.NetCore3.1 和 QuickFIXn 问题 #571）

4

0 回答 0