信任Client的Root CA

目前,我們告知RabbitMQ查看testca/cacert.pem 文件. 這包含了我們test認證中心的公共證書. 我們可能存在由多個不同認證中心簽發的證書，我們希望RabbitMQ全部信任它們.因此，我們可以簡單地將這些證書追加到另一個新文件中，以作為RabbitMQ的cacerts參數：

# cat testca/cacert.pem >> all_cacerts.pem # cat otherca/cacert.pem >> all_cacerts.pem

提供證書密碼

可使用password選項來為私有密鑰提供密碼：

[  {rabbit, [            {ssl_listeners, [5671]},            {ssl_options, [{cacertfile,"/path/to/ca_certificate.pem"},                           {certfile,  "/path/to/server_certificate.pem"},                           {keyfile,   "/path/to/server_key.pem"},                           {password,  "t0p$3kRe7"}                          ]}           ]} ]. 

了解 TLS 漏洞: POODLE, BEAST, etc

POODLE

POODLE 是一個已知的能破壞SSLv3的SSL/TLS攻擊.從3.4.0版本開始, RabbitMQ服務器拒絕接受SSLv3連接. 在2014年12月,一個經過改良的能影響TLSv1.0的POODLE攻擊被 宣布. 因此，建議使用Erlang 18.0＋的版本( 消除了TLS 1.0 POODLE攻擊漏洞）或者禁用TLSv1.0支持 (參考下面的章節）.

BEAST

BEAST attack 是一個能攻擊TLSv1.0的漏洞. 為了減輕它的攻擊,禁用TLSv1.0支持(參考下面的章節).

通過配置來禁用 SSL/TLS 版本

為了限制SSL/TLS協議版本,使用版本選項:

%% Disable SSLv3.0 support, leaves TLSv1.0 enabled. [  {ssl, [{versions, ['tlsv1.2', 'tlsv1.1', tlsv1]}]},  {rabbit, [            {ssl_listeners, [5671]},            {ssl_options, [{cacertfile,"/path/to/ca_certificate.pem"},                           {certfile,  "/path/to/server_certificate.pem"},                           {keyfile,   "/path/to/server_key.pem"},                           {versions, ['tlsv1.2', 'tlsv1.1', tlsv1]}                          ]}           ]} ]. 

%% Disable SSLv3.0 and TLSv1.0 support. [  {ssl, [{versions, ['tlsv1.2', 'tlsv1.1']}]},  {rabbit, [            {ssl_listeners, [5671]},            {ssl_options, [{cacertfile,"/path/to/ca_certificate.pem"},                           {certfile,  "/path/to/server_certificate.pem"},                           {keyfile,   "/path/to/server_key.pem"},                           {versions, ['tlsv1.2', 'tlsv1.1']}                          ]}           ]} ]. 

# connect using SSLv3 openssl s_client -connect 127.0.0.1:5671 -ssl3 

# connect using TLSv1.0 through v1.2 openssl s_client -connect 127.0.0.1:5671 -tls1 

SSL-Session:   Protocol  : TLSv1 

JDK 和 .NET支持的TLS版本

• .NET versions source.
• JDK versions source.

配置密碼套件

可配置RabbitMQ使用的密碼套件.注意現在所有的套件都可以在所有系統上使用. 例如，使用橢圓曲線密碼，請運行最新的Erlang發布。下面的例子演示了如何使用TLS的密碼選項。

%% List allowed ciphers [  {ssl, [{versions, ['tlsv1.2', 'tlsv1.1']}]},  {rabbit, [            {ssl_listeners, [5671]},            {ssl_options, [{cacertfile,"/path/to/ca_certificate.pem"},                           {certfile,  "/path/to/server_certificate.pem"},                           {keyfile,   "/path/to/server_key.pem"},                           {versions, ['tlsv1.2', 'tlsv1.1']},                           {ciphers,  [{ecdhe_ecdsa,aes_128_cbc,sha256},                                       {ecdhe_ecdsa,aes_256_cbc,sha}]}                          ]}           ]} ]. 

要列出Erlang 運行時安裝的所有密碼套件，可使用：

rabbitmqctl eval 'ssl:cipher_suites(openssl).' 

密鑰管理器，信任管理器，以及密鑰庫

在Java安全框架中，有三個需要注意的組件: 密鑰管理, 信任管理以及密鑰庫.

密鑰管理器用于對待節點管理其證書.也就是說，在會話設置時，密鑰管理會控制發送哪些證書給遠端對待節點．

信任管理器用于對等節點管理遠程證書.也就是說，在會話設置時，信任管理遠端節點的那些證書是可信任的．

密鑰庫是證書的Java封裝. Java會將證書轉換為Java特定的二進制格式或PKCS#12格式. 這些格式是使用Key Store類來管理的.對于服務端證書，我們會使用Java二進制格式，但對于客戶端 密鑰/證書對，我們將使用 PKCS#12格式.

沒有驗證證書的連接

我們的第一個示例將展示一個簡單的client,通過不驗證證書以及不存在任何客戶端證書的SSL來連接RabbitMQ服務器．

import java.io.*; import java.security.*;   import com.rabbitmq.client.*;  publicclass Example1 {     public　static　void main(String[] args) throws Exception     {          ConnectionFactory factory = new ConnectionFactory();         factory.setHost("localhost");         factory.setPort(5671);          factory.useSslProtocol();         // Tells the library to setup the default Key and Trust managers for you

　　// which do not do any form of remote server trust verification          Connection conn = factory.newConnection();         Channel channel = conn.createChannel();          //non-durable, exclusive, auto-delete queue         channel.queueDeclare("rabbitmq-java-test", false, true, true, null);         channel.basicPublish("", "rabbitmq-java-test", null, "Hello, World".getBytes());           GetResponse chResponse = channel.basicGet("rabbitmq-java-test", false);         if(chResponse == null) {             System.out.println("No message retrieved");         } else {             byte[] body = chResponse.getBody();             System.out.println("Recieved: " + new String(body));         }           channel.close();         conn.close();     } }

這個簡單的示例只是一個echo test.它會創建一個rabbitmq-java-test隊列，并向默認direct交換器中發送消息，然后讀回發布的消息，并進行回顯. 注意，我們使用的是專用的，非持久化，自動刪除的隊列，因此我們不需要擔心后期的手動清除.

存在和驗證證書

首先，我們需要設置密鑰庫.我們假設有要連接的服務器的證書，所以我們現在需要將它添加到我們的密鑰庫中(信任管理器會使用).

# keytool -import -alias server1 -file /path/to/server/cert.pem -keystore /path/to/rabbitstore

上面的命令會將cert.pem導入到rabbitstore中，并在內部稱其為server1. alias參數用于有多個證書或密鑰的時候用于指定別名，因為在內部必須有不同的名稱.

在關于是否相信證書的問題上，必須回答yes, 并要選擇一個密碼. 在這個例子中，我的密碼為rabbitstore。

然后我們要用PKCS#12文件中的客戶端證書和密鑰，已經在上面展示過了．

下面的例子會修改上面的代碼, 以使用我們的密鑰庫，密鑰管理器，以及信任管理器：

import java.io.*;   import java.security.*;   import javax.net.ssl.*;    import com.rabbitmq.client.*;     publicclass Example2   {       publicstaticvoid main(String[] args) throws Exception       {          char[] keyPassphrase = "MySecretPassword".toCharArray();         KeyStore ks = KeyStore.getInstance("PKCS12");         ks.load(new FileInputStream("/path/to/client/keycert.p12"), keyPassphrase);          KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");         kmf.init(ks, passphrase);          char[] trustPassphrase = "rabbitstore".toCharArray();         KeyStore tks = KeyStore.getInstance("JKS");         tks.load(new FileInputStream("/path/to/trustStore"), trustPassphrase);          TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509");         tmf.init(tks);          SSLContext c = SSLContext.getInstance("TLSv1.1");         c.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null);          ConnectionFactory factory = new ConnectionFactory();         factory.setHost("localhost");         factory.setPort(5671);         factory.useSslProtocol(c);          Connection conn = factory.newConnection();         Channel channel = conn.createChannel();          channel.queueDeclare("rabbitmq-java-test", false, true, true, null);         channel.basicPublish("", "rabbitmq-java-test", null, "Hello, World".getBytes());           GetResponse chResponse = channel.basicGet("rabbitmq-java-test", false);         if(chResponse == null) {             System.out.println("No message retrieved");         } else {             byte[] body = chResponse.getBody();             System.out.println("Recieved: " + new String(body));         }           channel.close();         conn.close();     } }

為了確保上述代碼能在其它情況下工作，可使用未導入到密鑰庫中的安全證書來嘗試，這時你可能會看到屏幕上的難異常信息.

RFC 5280, Certificate Key Usage and Mono

正如上面所提到的，Mono是相當嚴格的，強制證書只能應用于它聲明的特定目的．

SSL 證書和密鑰可應用于各種各樣的用途, 例如, 電子郵件簽名,代碼簽名, 通信加密等等. (我們這里的目的是TCP 通信加密). RFC 5280 指定了許多不同的目的, 并允許一個證書為特定的一組目的進行簽名．

SSL v3 證書可包含許多不同的擴展.處理證書如何使用的擴展被稱為Key Usage Extension. 不同使用一般來說，都支持得很好，即使是定義良好,它們的使用也是廣泛地解釋. 一些關鍵的用法已經廢棄，大部分已經完全忽視。

這里有一個更進一步的擴展, 它也指定了使用用途, 但它選擇O.I.Ns來進行, 如"1.3.6.1.5.5.7.3.1".顯然，英語缺乏一些明顯的用于添加的隨機數字。這是一個擴展密鑰使用擴展，序列的對象標識符，進一步定義了那些證書的使用是允許的。

而Mono,看上去認為這些擴展都是重要的, 需要有待進一步的觀察. 如果證書遺漏了Key Usage Extension，Mono會讓證書無效.默認情況下， OpenSSL 對于自簽名證書省略了Key Usage Extension ，因為它希望如果沒有找到Key Usage Extension, 該證書是有效的，可用于任何目的。

這就是為什么在樣例openssl.cnf文件的列舉中，root_ca_extensions, client_ca_extensions 和 server_ca_extensions 都指定了keyUsage,并且最后兩個還有extendedKeyUsage定義.因此上面生成的證書對于Mono的使用是有效的; keyEncipherment 指定了證書可通過SSL服務器來使用, digitalSignature指定了證書可由SSL客戶端使用. extendedKeyUsage 字段中的值都說了同樣的事情.

你可以使用this small tool 來檢查Mono是否接受RabbitMQ提供的證書. 注意，你需要使用合適的OpenSSL命令來轉換server/cert.pem 到tserver/cert.cer:

# openssl x509 -in /path/to/server/cert.pem -out /path/to/server/cert.cer -outform DER # mono certcheck.exe /path/to/server/cert. Checking if certificate is SSLv3... Ok Checking for KeyUsageExtension (2.5.29.15)... Ok Checking if KeyEncipherment flag is set... Ok This certificate CAN be used by Mono for Server validation 

TLS對等驗證：你說誰呢你？

在.NET平臺上，默認情況下，你連接的服務器的hostname需要匹配服務器安全證書上的CN (Common Name) 字段, 否則證書將會被拒絕.這就是為什么在指南開頭的命令中指定了 ...-subj /CN=$(hostname)/... 它會動態地查找你的主機名．如果你在一臺機器上生成,要在其它機器上使用那么必須交換$(hostname)部分,并使用你服務器正確的hostname來代替.

為了抑制匹配檢查，一個應用程序可以在SslOptions.AcceptablePolicyErrors中設置 System.Net.Security.SslPolicyErrors.RemoteCertificateNameMismatch 標志.

SslOptions.CertificateValidationCallback 可用來提供一個RemoteCertificateValidationCallback 代表. 代表會用適合應用程序的任何邏輯來驗證對等節點(RabbitMQ節點)的身份.如果沒有指定, 默認的回調將會聯合AcceptablePolicyErrors屬性來確定遠程服務器證書是否有效．

SslOption.CertificateSelectionCallback 可用來提供一個LocalCertificateSelectionCallback ，它將在對等節點驗證中選擇要用的本地安全證書.

信任 .Net

在 .NET 平臺上, 遠程證書是通過任意數量的存儲庫來管理的.這些存儲庫的管理是通過 'certmgr'(Microsoft .Net 實現和Mono都可用)工具來完成的．

NB: 在某些Windows平臺上，有兩種版本的命令-一個是隨著操作系統自帶的，只提供了圖形界面，另一個Windows SDK自帶的，提供了圖形界面和命令行界面. 兩者都可以很好的完成工作，但示例將以后者為基礎．

對于我們的情況,因為我們提供的客戶端certificate/key對都在單獨的PKCS #12 文件中，我們要做的只是導入根證書機構的證書到Root (Windows) / Trust(Mono) 存儲庫中.在存儲庫中所有簽名的證書都是自動可信的．

對比java客戶端，會樂于使用SSL連接而不驗證服務器的證書，該.Net客戶端需要驗證成功。為阻止驗證，應用程序可在SslOptions.AcceptablePolicyErrors中設置System.Net.Security.SslPolicyErrors.RemoteCertificateNotAvailable 以及System.Net.Security.SslPolicyErrors.RemoteCertificateChainErrors 標志．

Certmgr證書管理

certmgr 允許Add, Delete, List 以及在特定的Store上執行其它操作.這些stores 可以是用戶stores, 或機器范圍的.只有管理員用戶有機器范圍stores的寫訪問權限．

為了將證書加入users Root (Windows) / Trust (Mono) store，我們可以運行:

(Windows) > certmgr -add -all \path\to\cacert.cer -s Root (Mono)    $ certmgr -add -c Trust /path/to/cacert.cer

將證書加入機器證書存儲庫，我們要運行

(Windows) > certmgr -add -all \path\to\cacert.cer -s -r localMachine Root (Mono)    $ certmgr -add -c -m Trust /path/to/cacert.cer

在將證書添加到store后，我們可以用-list命令來展示證書內容:

(Windows) > certmgr -all -s Root (Mono)    $ certmgr -list -c Trust  Mono Certificate Manager - version 2.4.0.0 Manage X.509 certificates and CRL from stores. Copyright 2002, 2003 Motus Technologies. Copyright 2004-2008 Novell. BSD licensed.  Self-signed X.509 v3 Certificate   Serial Number: AC3F2B74ECDD9EEA00   Issuer Name:   CN=MyTestCA   Subject Name:  CN=MyTestCA   Valid From:    25/08/2009 14:03:01   Valid Until:   24/09/2009 14:03:01   Unique Hash:   1F04D1D2C20B97BDD5DB70B9EB2013550697A05E

正如我們看到的，在信任庫里有一個自簽名的X.509 v3 證書. Unique Hash在store里是唯一的標識符. 

要刪除這個證書,可使用unique hash:

(Windows) > certmgr -del -c -sha1 1F04D1D2C20B97BDD5DB70B9EB2013550697A05E -s Root (Mono)    $ certmgr -del -c Trust 1F04D1D2C20B97BDD5DB70B9EB2013550697A05E  Mono Certificate Manager - version 2.4.0.0 Manage X.509 certificates and CRL from stores. Copyright 2002, 2003 Motus Technologies. Copyright 2004-2008 Novell. BSD licensed.  Certificate removed from store.

使用相同的步驟，我們可以在客戶端上也可以執行add/delete/list 我們根證書的操作．

創建連接

要創建RabbitMQ的SSL連接,我們需要在ConnectionFactory參數字段中設置一些新字段.為了讓事情更簡單，這里有一新字段Parameters.Ssl，它可作為需要設置所有其它字段的命名空間 . 這些字段是:

• Ssl.CertPath: 如果你的服務器希望驗證客戶端的話，這是PKCS#12格式的客戶端證書的路徑.這是可選的.
• Ssl.CertPassphrase:如果你正在使用ＰKCS#12 格式的客戶端證書，那么可能會需要一個密碼，你可以在這個字段中進行指定.
• Ssl.Enabled: 這是一個boolean字段，用以打開或關閉SSL支持.默認是off.
• Ssl.ServerName: 記住 .Net希望這匹配發送證書的CN.

例子

這與Java部分的例子是一樣的.它創建了一個channel, rabbitmq-dotnet-test隊列，并使用默認direct交換器來發布,然后再讀回發送的消息并進行回顯.注意，我們使用的是exclusive, non-durable, auto-delete隊列，因此我們不必擔憂事后的手動清除．

using System; using System.IO; using System.Text;  using RabbitMQ.Client; using RabbitMQ.Util;  namespace RabbitMQ.Client.Examples {   public class TestSSL {     public static int Main(string[] args) {       ConnectionFactory cf = new ConnectionFactory();        cf.Ssl.ServerName = System.Net.Dns.GetHostName();       cf.Ssl.CertPath = "/path/to/client/keycert.p12";       cf.Ssl.CertPassphrase = "MySecretPassword";       cf.Ssl.Enabled = true;        using (IConnection conn = cf.CreateConnection()) {         using (IModel ch = conn.CreateModel()) {           ch.QueueDeclare("rabbitmq-dotnet-test", false, false, false, null);           ch.BasicPublish("", "rabbitmq-dotnet-test", null,                           Encoding.UTF8.GetBytes("Hello, World"));           BasicGetResult result = ch.BasicGet("rabbitmq-dotnet-test", true);           if (result == null) {             Console.WriteLine("No message received.");           } else {             Console.WriteLine("Received:");             DebugUtil.DumpProperties(result, Console.Out, 0);           }           ch.QueueDelete("rabbitmq-dotnet-test");         }       }       return 0;     }   } } 

注意，在Windows XP上,運行此例，可能會出現失敗

  CryptographicException: Key not valid for use in specified state.

Erlang SSL 選項

必須提供三個重要選項:

• cacertfile 選項用于指定明確信任的根證書機構的證書.
• certfile是client擁有的PEM格式的證書
• keyfile是客戶端PEM格式的私有密鑰文件

作為RabbitMQ自身, verify 和fail_if_no_peer_cert 選項可用來指定當服務器未提供證書或我們不能根據服務器證書建立信任鏈時下的動作. depth配置了證書驗證的深度(參考上面部分).

代碼

Params = #amqp_params_network { port = 5671,                                 ssl_options = [{cacertfile, "/path/to/testca/cacert.pem"},                                                {certfile, "/path/to/client/cert.pem"},                                                {keyfile, "/path/to/client/key.pem"},                                                %% only necessary with intermediate CAs                                                %% {depth, 2},                                                {verify, verify_peer},                                                {fail_if_no_peer_cert, true}] }, {ok, Conn} = amqp_connection:start(Params), 

現在你就可以像普通連接一樣來使用Conn了.

TLS/SSL故障排除

ssl:versions().

[{ssl_app,"5.3.6"},  {supported,['tlsv1.2','tlsv1.1',tlsv1]},  {available,['tlsv1.2','tlsv1.1',tlsv1]}] 

openssl s_server -accept 8443 -cert server/cert.pem -key server/key.pem \   -CAfile testca/cacert.pem

openssl s_client -connect localhost:8443 -cert client/cert.pem -key client/key.pem \   -CAfile testca/cacert.pem

Verify return code: 0 (ok)

=INFO REPORT==== 8-Aug-2011::11:51:47 === started SSL Listener on 0.0.0.0:5671

openssl s_client -connect localhost:5671 -cert client/cert.pem -key client/key.pem \   -CAfile testca/cacert.pem

=INFO REPORT==== 8-Aug-2011::11:55:13 === accepting AMQP connection <0.223.0> (127.0.0.1:58954 -> 127.0.0.1:5671)

如果你現在為broker提供８個隨機字節,broker將會使用字符串"AMQP"緊跟編碼的版本號數字進行回復. 如果你認出了"AMQP"字符串，那么你能確定你已經連接上了AMQP broker.

cat client/key.pem client/cert.pem > client/key-cert.pem stunnel -r localhost:5672 -d 5679 -f -p client/key-cert.pem -D 7