林 先森 2018-06-22 02:19 采纳率: 0%
浏览 7236
已结题

RabbitMQ 插件MQTT使用

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

  • 写回答

3条回答 默认 最新

  • 邪恶八进制 2018-06-22 02:34
    关注
     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

    评论

报告相同问题?

悬赏问题

  • ¥15 求差集那个函数有问题,有无佬可以解决
  • ¥15 【提问】基于Invest的水源涵养
  • ¥20 微信网友居然可以通过vx号找到我绑的手机号
  • ¥15 寻一个支付宝扫码远程授权登录的软件助手app
  • ¥15 解riccati方程组
  • ¥15 display:none;样式在嵌套结构中的已设置了display样式的元素上不起作用?
  • ¥15 使用rabbitMQ 消息队列作为url源进行多线程爬取时,总有几个url没有处理的问题。
  • ¥15 Ubuntu在安装序列比对软件STAR时出现报错如何解决
  • ¥50 树莓派安卓APK系统签名
  • ¥65 汇编语言除法溢出问题