rabbitmq系列（二）幾種常見模式的應用場景及實現

阿新 • • 發佈：2020-01-15

一、簡單模式

原理：生產者將訊息交給預設的交換機，交換機獲取訊息後交給繫結這個生產者的佇列（投遞規則為佇列名稱和routing key 相同的佇列），監聽當前佇列的消費者獲取資訊並執行消費邏輯。

場景：有一個oa系統，使用者通過接收手機驗證碼進行註冊，頁面上點選獲取驗證碼後，將驗證碼放到訊息佇列，然後簡訊服務從佇列中獲取到驗證碼，併發送給使用者。

實現：

生產者：

public class Producter {

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

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();
        // 4. 通過channel釋出訊息
        /**
         * 四個引數：
         * 第一個引數是交換機的名稱
         * 第二個引數是路由鍵
         * 第三個引數標識訊息的一些額外的屬性
         * 第四個是訊息的具體的內容
         */
        String message = "位元組";
        for(int i = 0;i < 5;i ++){

            channel.basicPublish("","byte001",null,message.getBytes());
        }
        // 5. 釋放資源，釋放channel 和 連結物件

        channel.close();
        connection.close();
    }
}

消費者：

public class Consumer {

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

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        // 4. 創建出訊息佇列
        /**
         * 第一個引數是訊息佇列的名稱
         * 第二個引數表示訊息是否持久化
         * 第三個引數標識訊息佇列是否被channel獨佔
         * 第四個引數標識是否自動刪除訊息佇列，當訊息佇列沒有繫結交換機後是否自動刪除
         * 第五個是訊息佇列擴充套件引數
         */
        String queueName = "byte001";
        channel.queueDeclare(queueName, true, false, false, null);

        // 5. 建立消費者,對訊息進行處理
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("獲取到的訊息："+s);
            }
        };
        // 6. 通過channel消費者和訊息佇列關聯
        /**
         * 第一個引數是訊息佇列的名字
         * 第二個引數是否自動簽收（即消費訊息後告知伺服器已被消費）
         * 第三個引數是消費者
         */
        channel.basicConsume(queueName, true, consumer);
    }
}

二、工作模式

原理：生產者將訊息交給交換機，交換機交給繫結的佇列，佇列有多個消費者監聽，一條訊息只能由一個消費者消費，這樣就形成了資源競爭，誰的資源空閒大，爭搶到的可能性就大。

場景：有一個電商平臺，有兩個訂單服務，使用者下單的時候，任意一個訂單服務消費使用者的下單請求生成訂單即可。不用兩個訂單服務同時消費使用者的下單請求。

實現：

生產者：

public class Producter {

    public static final String QUEUE_NAME = "byte002";
    public static void main(String[] args) throws Exception {

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        // 申明佇列
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);
        // 4. 通過channel釋出訊息
        /**
         * 四個引數：
         * 第一個引數是交換機的名稱
         * 第二個引數是路由鍵
         * 第三個引數標識訊息的一些額外的屬性
         * 第四個是訊息的具體的內容
         */
        String message = "位元組";
        for(int i = 0;i < 100;i ++){

            channel.basicPublish("",QUEUE_NAME,null,(message+i).getBytes());
        }
        // 5. 釋放資源，釋放channel 和 連結物件

        channel.close();
        connection.close();
    }
}

消費者1：

public class Consumer {

    public static final String QUEUE_NAME = "byte002";
    public static void main(String[] args) throws Exception {

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        // 4. 創建出訊息佇列
        /**
         * 第一個引數是訊息佇列的名稱
         * 第二個引數表示訊息是否持久化
         * 第三個引數標識訊息佇列是否被channel獨佔
         * 第四個引數標識是否自動刪除訊息佇列，當訊息佇列沒有繫結交換機後是否自動刪除
         * 第五個是訊息佇列擴充套件引數
         */
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        channel.basicQos(1); // 告訴伺服器，在我們沒有確認當前訊息時不要給我們傳送新的訊息
        // 5. 建立消費者,對訊息進行處理
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者1收到的內容："+s);
                try {
                    Thread.sleep(10); // 模擬消費耗時
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                channel.basicAck(envelope.getDeliveryTag(),false); // 引數2false為確認收到訊息，true為拒絕收到訊息
            }
        };
        // 6. 通過channel消費者和訊息佇列關聯
        /**
         * 第一個引數是訊息佇列的名字
         * 第二個引數是否自動簽收（即消費訊息後告知伺服器已被消費）
         * 第三個引數是消費者
         */
        channel.basicConsume(QUEUE_NAME, false, consumer);
    }
}

消費者2：

public class Consumer2 {

    public static final String QUEUE_NAME = "byte002";
    public static void main(String[] args) throws Exception {

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        // 4. 創建出訊息佇列
        /**
         * 第一個引數是訊息佇列的名稱
         * 第二個引數表示訊息是否持久化
         * 第三個引數標識訊息佇列是否被channel獨佔
         * 第四個引數標識是否自動刪除訊息佇列，當訊息佇列沒有繫結交換機後是否自動刪除
         * 第五個是訊息佇列擴充套件引數
         */
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        channel.basicQos(1); // 告訴伺服器，在我們沒有確認當前訊息時不要給我們傳送新的訊息
        // 5. 建立消費者,對訊息進行處理
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者2收到的內容："+s);
                try {
                    Thread.sleep(500); // 模擬消費耗時
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                channel.basicAck(envelope.getDeliveryTag(),false); // 引數2false為確認收到訊息，true為拒絕收到訊息
            }
        };
        // 6. 通過channel消費者和訊息佇列關聯
        /**
         * 第一個引數是訊息佇列的名字
         * 第二個引數是否自動簽收（即消費訊息後告知伺服器已被消費）
         * 第三個引數是消費者
         */
        channel.basicConsume(QUEUE_NAME, false, consumer);
    }
}

保證資源競爭的程式碼就是這一行channel.basicQos(1);如果不加這一行，我們會發現兩個消費者是輪詢消費訊息的。

三、釋出訂閱模式

原理：生產者將訊息扔給交換機，交換機型別是fanout，不同的佇列註冊到交換機上，不同的消費註冊在不同的佇列上。所有消費者都會收到訊息。

場景：有一個商城，我們新新增一個商品後，可能同時需要去更新快取和資料庫。

實現：

生產者：

public class Producter {

    // 定義交換機的名字
    public static final String EXCHANGE_NAME="byte003";
    public static void main(String[] args) throws Exception {

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();
        // 定義一個交換機，型別是fanout
        channel.exchangeDeclare(EXCHANGE_NAME,"fanout");

        // 因為訊息先發到交換機，交換機沒有儲存功能，所以如果沒有消費者，訊息會丟失
        channel.basicPublish(EXCHANGE_NAME,"",null,"釋出訂閱模式的訊息".getBytes());

        channel.close();
        connection.close();
    }
}

消費者1：

public class Consumer1 {
    public static final String EXCHANGE_NAME="byte003";

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


        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        String queueName = "queue003";
        channel.queueDeclare(queueName,false,false,false,null);

        // 繫結佇列到交換機
        channel.queueBind(queueName,EXCHANGE_NAME,"");
        channel.basicQos(1);
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者1："+s);
                channel.basicAck(envelope.getDeliveryTag(),false);
            }
        };
        channel.basicConsume(queueName,false,consumer);
    }
}

消費者2：

public class Consumer2 {
    public static final String EXCHANGE_NAME="byte003";

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


        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        String queueName = "queue004";
        channel.queueDeclare(queueName,false,false,false,null);

        // 繫結佇列到交換機
        channel.queueBind(queueName,EXCHANGE_NAME,"");
        channel.basicQos(1);
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者2："+s);
                channel.basicAck(envelope.getDeliveryTag(),false);
            }
        };
        channel.basicConsume(queueName,false,consumer);
    }
}

需要注意的一點就是交換機沒有儲存功能，如果沒有消費者，則訊息會丟失。

四、路由模式

原理：生產者將訊息傳送給交換機，訊息攜帶具體的routingkey。交換機型別是direct，接收到訊息中的routingkey，比對與之繫結的佇列的routingkey，分發到不同的佇列上。

場景：還是一樣，有一個商城，新添加了一個商品，實時性不是很高，只需要新增到資料庫即可，不用重新整理快取。

實現：

生產者：

public class Producter {

    // 定義交換機的名字
    public static final String EXCHANGE_NAME="byte004";
    public static void main(String[] args) throws Exception {

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();
        // 定義一個交換機，型別是direct
        channel.exchangeDeclare(EXCHANGE_NAME,"direct");

        // 因為訊息先發到交換機，交換機沒有儲存功能，所以如果沒有消費者，訊息會丟失
        channel.basicPublish(EXCHANGE_NAME,"key1",null,"釋出路由模式的訊息".getBytes());

        channel.close();
        connection.close();
    }
}

消費者1：

public class Consumer1 {
    public static final String EXCHANGE_NAME="byte004";

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


        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        String queueName = "queue005";
        channel.queueDeclare(queueName,false,false,false,null);

        // 繫結佇列到交換機
        /**
         * 引數3是routingkey，只有和它一樣的routingkey的訊息才會被當前消費者收到
         */
        channel.queueBind(queueName,EXCHANGE_NAME,"key1");
        // 如果要接收多個routingkey的訊息，在執行一次上面的程式碼即可，如下
        channel.queueBind(queueName,EXCHANGE_NAME,"key2");
        channel.basicQos(1);
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者1："+s);
                channel.basicAck(envelope.getDeliveryTag(),false);
            }
        };
        channel.basicConsume(queueName,false,consumer);
    }
}

消費者2：

public class Consumer2 {
    public static final String EXCHANGE_NAME="byte004";

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


        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        String queueName = "queue006";
        channel.queueDeclare(queueName,false,false,false,null);

        // 繫結佇列到交換機
        channel.queueBind(queueName,EXCHANGE_NAME,"key2");
        channel.basicQos(1);
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者2："+s);
                channel.basicAck(envelope.getDeliveryTag(),false);
            }
        };
        channel.basicConsume(queueName,false,consumer);
    }
}

五、主題模式

原理：路由模式的一種，路由功能添加了模糊匹配。星號（*）代表1個單詞，#號（#）代表一個或多個單詞。具體可參考路由模式。

場景：還是一樣，有一個商城，新添加了一個商品，實時性不是很高，只需要新增到資料庫即可，資料庫包含了主資料庫mysql1和從資料庫mysql2的內容，不用重新整理快取。

實現：

生產者：

public class Producter {

    // 定義交換機的名字
    public static final String EXCHANGE_NAME="byte004";
    public static void main(String[] args) throws Exception {

        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();
        // 定義一個交換機，型別是topic
        channel.exchangeDeclare(EXCHANGE_NAME,"topic");

        // 因為訊息先發到交換機，交換機沒有儲存功能，所以如果沒有消費者，訊息會丟失
        channel.basicPublish(EXCHANGE_NAME,"key.1.2",null,"釋出路由模式的訊息".getBytes());

        channel.close();
        connection.close();
    }
}

消費者1：

public class Consumer1 {
    public static final String EXCHANGE_NAME="byte004";

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


        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        String queueName = "queue005";
        channel.queueDeclare(queueName,false,false,false,null);

        // 繫結佇列到交換機
        /**
         * 引數3是routingkey，只有和它一樣的routingkey的訊息才會被當前消費者收到
         */
        channel.queueBind(queueName,EXCHANGE_NAME,"key.*");
        // 如果要接收多個routingkey的訊息，在執行一次上面的程式碼即可，如下
        channel.queueBind(queueName,EXCHANGE_NAME,"abc.#");
        channel.basicQos(1);
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者1："+s);
                channel.basicAck(envelope.getDeliveryTag(),false);
            }
        };
        channel.basicConsume(queueName,false,consumer);
    }
}

消費者2：

public class Consumer2 {
    public static final String EXCHANGE_NAME="byte004";

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


        // 1. 創建出連結工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");

        // 2. 通過連結工廠建立連結物件
        Connection connection = factory.newConnection();

        // 3. 通過連結物件創建出channel
        Channel channel = connection.createChannel();

        String queueName = "queue006";
        channel.queueDeclare(queueName,false,false,false,null);

        // 繫結佇列到交換機
        channel.queueBind(queueName,EXCHANGE_NAME,"key.#");
        channel.basicQos(1);
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             * consumerTag 用來標識.可以再監聽佇列時候設定
             * envelope 信封,通過envelope可以通過這個獲取到很多東西
             * properties 額外的訊息屬性
             * body:訊息體
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                String s = new String(body, "UTF-8");
                System.out.println("消費者2："+s);
                channel.basicAck(envelope.getDeliveryTag(),false);
            }
        };
        channel.basicConsume(queueName,false,consumer);
    }
}

程式碼已上傳：

github地址： https://github.com/binzh303/zhixie-code-example

gitee地址： https://gitee.com/javaXiaoCaiJi/zhixie-code-example

如果文章對您有幫助，請記得點贊關注喲~
歡迎大家關注我的公眾號：位元組傳說，每日推送技術文章供大家學習參考。

rabbitmq系列（二）幾種常見模式的應用場景及實現

一、簡單模式原理：生產者將訊息交給預設的交換機，交換機獲取訊息後交給繫結這個生產者的佇列（投遞規則為佇列名稱和routing key 相同的佇列），監聽當前佇列的消費者獲取資訊並執行消費邏輯。場景：有一個oa系統，使用者通過接收手機驗證碼進行註冊，頁面上點選獲取驗證碼後，將驗證碼放到訊息佇列，然後簡訊

MNIST手寫數字識別（二）幾種模型優化方式介紹

本篇的主要內容有：動態衰減法設定可變學習率為損失函式新增正則項滑動平均模型介紹為了讓MNIST數字識別模型更準確，學習幾種常用的模型優化手段：學習率的優化學習率的設定一定程度上也會影響模型的訓練，如果學習率過小，那麼將會經過很長時間才會收斂到想要

分散式設計與開發（二）------幾種必須瞭解的分散式演算法

分散式設計與開發中有些疑難問題必須藉助一些演算法才能解決，比如分散式環境一致性問題，感覺以下分散式演算法是必須瞭解的（隨著學習深入有待新增）： Paxos演算法一致性Hash演算法 Paxos演算法 1）問題描述分散式中有這麼一個疑難問題，客戶端向一個分散式叢集的服務

Tensorflow學習筆記（六）幾種常見的啟用函式介紹及用matplotlib畫圖

歷史上，sigmoid函式曾非常常用，然而現在它已經不太受歡迎，實際很少使用了，因為它主要有兩個缺點： 1. 函式飽和使梯度消失：sigmoid 神經元在值為 0 或 1的時候接近飽和，這些區域，梯度幾乎為 0。因此在反向傳播時，這個區域性梯度會與整個代價函式關於該單元輸出的梯度相乘，結果也會接近為

建立物件（二）——三種基本模式的組合使用

一、建構函式模式和原型模式的組合使用建立自定義型別的最常用方式 function Person(name,age,job){ this.name=name; this.age=age; this.job=job; this.fr

程式設計師之網路安全系列（二）：如何安全儲存使用者密碼及雜湊演算法

系列目錄: 前言在很多網站的早期，甚至是現在仍然有一些網站，當你點選忘記密碼功能時，你的郵箱會收到一封郵件，然後裡面赫然寫著你的密碼，很多普通使用者還會覺得慶幸，總算是找回來了，殊不知，這是多麼可怕地一件事，說明了網站是“幾乎是”明文儲存你的密碼，一旦資料使用者資料洩露或者被拖庫，那麼使用者密碼將赤裸裸

dubbo原始碼分析（二）：超時原理以及應用場景

本篇主要記錄dubbo中關於超時的常見問題，實現原理，解決的問題以及如何在服務降級中體現作用等。超時問題為了檢查對dubbo超時的理解，嘗試回答如下幾個問題，如果回答不上來或者不確定那麼說明此處需要再多研究研究。我只是針對個人的理解提問題，並不代表我理解的就是全面深入的，但我的問題如果也回答不

單例模式應用場景及實現（By C++）

單例模式是一種常用的軟體設計模式。在它的核心結構中只包含一個被稱為單例類的特殊類。通過單例模式可以保證系統中一個類只有一個例項而且該例項易於外界訪問，從而方便對例項個數的控制並節約系統資源。如果希望在系統中某個類的物件只能存在一個，單例模式是最好的解決方案。

android launchmode(四種啟動模式)應用場景及例項

我們在開發專案的過程中，會涉及到該應用中多個Activity元件之間的跳轉，或者夾帶其它應用的可複用的Activity。例如我們可能希望跳轉到原來某個Activity例項，而不是產生大量重複的 Activity。這樣就需要我們為 Activity 配置特定的載入模式，而不

訊息中介軟體（二）訊息佇列常見的幾種使用場景介紹

一、訊息佇列概述訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題。實現高效能，高可用，可伸縮和最終一致性架構。是大型分散式系統不可缺少的中介軟體。目前在生產環境，使用較多的訊息佇列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaM

Linux系統運維常見面試簡答題系列（二）（14題）

local 企業 nginx服務簡答題 ip協議 php out gin 報錯 1. /var/log/messages日誌出現kernel:nf_conntrack:tablefull,dropping packet,請問是什麽原因導致的，如何解決？此報錯為iptab

Linux VPS/服務器建站系列（二）- 常見的國內雲服務器商家

數據中心 log 中心相互網站能說之前體積選擇繼續接"Linux VPS/服務器建站系列（一）- 哪些人需要用服務器建站"文章，既然我們開始決定選擇VPS、服務器作為項目用途。在準備實際的操作之前，筆者先準備羅列國內和國外的常見雲服務器商家。因為服務器商家和方

深度學習基礎系列（二）| 常見的Top-1和Top-5有什麽區別？

ack [1] 隨機排名 array gen spa imp 概率分布　　在深度學習過程中，會經常看見各成熟網絡模型在ImageNet上的Top-1準確率和Top-5準確率的介紹，如下圖所示：　　那Top-1 Accuracy和Top-5 Accuracy是指什

HTTP系列（二）—— 常見的HTTP狀態碼

目錄 1. 狀態碼的類別 2. 狀態碼詳解 2.1 成功狀態碼 2.2 重定向狀態碼 2.3 客戶端錯誤狀態碼 2.4 服務端錯誤狀態碼 HTTP狀態碼負責表示客戶端HTTP請求的返回結果、標記服務端處理是否正常、通知出現的

JVM調優系列（二）:從哪幾個角度考慮調優

你對JVM調優的方法瞭解多少，這裡和大家分享幾個，比如要升級JVM版本，如果能使用64-bit，使用64-bitJVM。基本上沒什麼好解釋的，很簡單將JVM升級到最新的版本。如果你還是使用JDK1.4甚至是更早的JVM，那你首先要做的就是升級。 JVM調優技巧總結這篇是技巧性的文章，如果要找關於G

stm32簡明教程系列（二）----GPIO(上)八種模式的區別與應用場合

一.概述 GPIO全稱為通用輸入/輸出埠。是stm32用於輸出訊號，輸入訊號的通道。他有以下八種模式：輸入方式浮空輸入 GPIO_Mode_IN_FLOATING 上拉GPIO_Mode_IPU 下拉GPIO_Mode_IPD 模擬輸入 GPIO_Mode_A

雪飲者決策樹系列（二）決策樹應用

ssi 字符串長度 mes pla 選擇 font com vector nac 　　本篇以信息增益最大作為最優化策略來詳細介紹決策樹的決策流程。　　首先給定數據集，見下圖　　註：本數據來源於網絡本篇將以這些數據作為訓練數據（雖然少，但足以介紹清楚原理！），下圖是決

數據結構系列（二）算法

nal log 如何空間復雜度計算 youdao 最好時間 bsp 高斯求和計算1+2+...+100 算法的概念就不多說了強調一點就是，沒有通用的算法，就像永遠沒有銀彈，所有的算法都有自己的適用領域評判算法好壞的方法復雜度用大O表示，又分為時間復雜度

（轉）8種常見機器學習算法比較

圖像在一起 test word 例子自己期望獲得樣本機器學習算法太多了，分類、回歸、聚類、推薦、圖像識別領域等等，要想找到一個合適算法真的不容易，所以在實際應用中，我們一般都是采用啟發式學習方式來實驗。通常最開始我們都會選擇大家普遍認同的算法，諸如SVM，G

rabbitmq系列（二）幾種常見模式的應用場景及實現

一、簡單模式

二、工作模式

三、釋出訂閱模式

四、路由模式

五、主題模式

相關推薦