RabbitMQ 插件MQTT使用

Question

如何开MQTT的SSL连接，Java如何使用 RabbitMQ如何开启SSL连接，并进行使用

Answer 1

 package test.rabbitmq;  

import com.rabbitmq.client.Channel;  
import com.rabbitmq.client.Connection;  
import com.rabbitmq.client.ConnectionFactory;  
import com.rabbitmq.client.GetResponse;  

import javax.net.ssl.KeyManagerFactory;  
import javax.net.ssl.SSLContext;  
import javax.net.ssl.TrustManagerFactory;  
import java.io.FileInputStream;  
import java.security.KeyStore;  

public class ValidatingCert  
{  
    public static void main(String[] args) throws Exception  
    {  

        char[] keyPassphrase = "rabbit".toCharArray();  
        KeyStore ks = KeyStore.getInstance("PKCS12");  
        ks.load(new FileInputStream("/etc/rabbitmq/ssl/client/rabbit-client.keycert.p12"), keyPassphrase);  

        KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");  
        kmf.init(ks, keyPassphrase);  

        char[] trustPassphrase = "rabbit".toCharArray();  
        KeyStore tks = KeyStore.getInstance("JKS");  
        tks.load(new FileInputStream("/etc/rabbitmq/ssl/keystore"), 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 via SSL".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();  
    }  
}  

java 启用RabbitMQ 地址：http://vstars.iteye.com/blog/2229409