AmazonMQ与.NET Core 2.0的集成

Question

AmazonMQ与.NET Core 2.0的集成

4

有人成功地使用.NET Core 2.0通过SSL连接到AmazonMQ吗？

我在使用Apache.NMS.ActiveMQ.Core包连接时遇到以下错误：

System.NotSupportedException: The requested security protocol is not supported.
   at System.Net.SecurityProtocol.ThrowOnNotAllowed(SslProtocols protocols, Boolean allowNone)
   at System.Net.Security.SslStream.AuthenticateAsClient(String targetHost, X509CertificateCollection clientCertificates, SslProtocols enabledSslProtocols, Boolean checkCertificateRevocation)
   at Apache.NMS.ActiveMQ.Transport.Tcp.SslTransport.CreateSocketStream()
   at Apache.NMS.ActiveMQ.Transport.Tcp.TcpTransport.Start()
   at Apache.NMS.ActiveMQ.Transport.WireFormatNegotiator.Start()
   at Apache.NMS.ActiveMQ.Connection.CheckConnected()
   at Apache.NMS.ActiveMQ.Connection.CreateActiveMQSession(AcknowledgementMode ackMode)
   at SendToMQ.Program.SendMessage() in C:\GITLab\POC\SendToMQ\SendToMQ\SendToMQ\Program.cs:line 40
   at SendToMQ.Program.Main(String[] args) in C:\GITLab\POC\SendToMQ\SendToMQ\SendToMQ\Program.cs:line 15

使用以下代码：

string url = "ssl://url:61617";
string userName = "name";
string password = "pw";


string payLoad = "This is a test.";
IConnectionFactory factory = new ConnectionFactory(new Uri(url));

using (IConnection connection = factory.CreateConnection(userName, password))
{
    using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
    {

        IDestination destination = Apache.NMS.Util.SessionUtil.GetDestination(session, "TestTopic");
        using (IMessageProducer producer = session.CreateProducer(destination))
        {
            connection.Start();

            ITextMessage request = session.CreateTextMessage(payLoad);
            request.Properties["id"] = 123;
            producer.Send(request);
        }
    }
}

谢谢您的提前帮助。

- Albert

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Jorrrit Visser · Accepted Answer

你需要创建一个SslFactory并将SslOption设置为Tls。否则，NMS会默认使用SslProtocol.Default（在Apache.NMS.ActiveMQ.Transport.Tcp.SslTransport.GetAllowedProtocol()中），这是Ssl3。

        String uri = "ssl://yourinstance:61617?nms.AsyncSend=true";
        ITransportFactory sslTransportFactory = new SslTransportFactory();
        ((SslTransportFactory)sslTransportFactory).SslProtocol = "Tls";
        ITransport transport = sslTransportFactory.CreateTransport(new Uri(uri));
        Connection connection = new Connection(new Uri(uri), transport, new IdGenerator())
        {
            UserName = "user",
            Password = "pwd"
        };
        ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
        IDestination dest = session.GetQueue("my_queue");
        IMessageProducer producer = session.CreateProducer(dest);
        producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
        var msg = session.CreateTextMessage("Some msg");
        producer.Send(msg);
        connection.Close();