主頁 > 後端開發 > RocketMQ 學習

RocketMQ 學習

2023-03-30 19:51:30 後端開發

前言

　　RocketMQ是阿里巴巴旗下一款開源的MQ框架，經歷過雙十一考驗、Java編程語言實作，有非常好完整生態系統，RocketMQ作為一款純java、分布式、佇列模型的開源訊息中間件，支持事務訊息、順序訊息、批量訊息、定時訊息、訊息回溯等

本篇文章第一部分屬于一些核心概念和作業流程的講解；第二部分就是純手動搭建了一套環境；第三部分是基于環境進行測驗和集成到SpringBoot

核心概念

  • NameServer：可以理解為是一個注冊中心，主要是用來保存topic路由資訊，管理Broker，在NameServer的集群中，NameServer與NameServer之間是沒有任何通信的，

  • Broker：核心的一個角色，主要是用來保存topic的資訊，接受生產者產生的訊息，持久化訊息，在一個Broker集群中，相同的BrokerName可以稱為一個Broker組，一個Broker組中,BrokerId為0的為主節點，其它的為從節點，BrokerName和BrokerId是可以在Broker啟動時通過組態檔配置的，每個Broker組只存放一部分訊息，

  • 生產者：生產訊息的一方就是生產者

  • 生產者組：一個生產者組可以有很多生產者，只需要在創建生產者的時候指定生產者組，那么這個生產者就在那個生產者組

  • 消費者：用來消費生產者訊息的一方

  • 消費者組：跟生產者一樣，每個消費者都有所在的消費者組，一個消費者組可以有很多的消費者，不同的消費者組消費訊息是互不影響的，

  • topic（主題）：可以理解為一個訊息的集合的名字，生產者在發送訊息的時候需要指定發到哪個topic下，消費者消費訊息的時候也需要知道自己消費的是哪些topic底下的訊息，

  • Tag（子主題）：比topic低一級，可以用來區分同一topic下的不同業務型別的訊息，發送訊息的時候也需要指定，

這里有組的概念是因為可以用來做到不同的生產者組或者消費者組有不同的配置，這樣就可以使得生產者或者消費者更加靈活，

作業流程

通過這張圖就可以很清楚的知道，RocketMQ大致的作業流程：

  • Broker啟動的時候，會往每臺NameServer（因為NameServer之間不通信，所以每臺都得注冊）注冊自己的資訊，這些資訊包括自己的ip和埠號，自己這臺Broker有哪些topic等資訊，

  • Producer在啟動之后會跟會NameServer建立連接，定期從NameServer中獲取Broker的資訊，當發送訊息的時候，會根據訊息需要發送到哪個topic去找對應的Broker地址，如果有的話，就向這臺Broker發送請求；沒有找到的話，就看根據是否允許自動創建topic來決定是否發送訊息，

  • Broker在接收到Producer的訊息之后，會將訊息存起來，持久化，如果有從節點的話，也會主動同步給從節點，實作資料的備份

  • Consumer啟動之后也會跟NameServer建立連接，定期從NameServer中獲取Broker和對應topic的資訊，然后根據自己需要訂閱的topic資訊找到對應的Broker的地址，然后跟Broker建立連接，獲取訊息，進行消費

就跟上面的圖一樣，整體的作業流程還是比較簡單的，這里簡化了很多概念，主要是為了好理解，

環境搭建

　　通過上面分析，我們知道，在RocketMQ中有NameServer、Broker、生產者、消費者四種角色，而生產者和消費者實際上就是業務系統，所以這里不需要搭建，真正要搭建的就是NameServer和Broker，但是為了方便RocketMQ資料的可視化，這里多搭建一套可視化的服務，

搭建程序比較簡單，按照步驟一步一步來就可以完成，如果提示一些命令不存在，那么直接通過yum安裝這些命令就行，

一、準備

需要準備一個linux服務器，需要先安裝好JDK

關閉防火墻

systemctl stop firewalld
systemctl disable firewalld

下載并解壓RocketMQ

1、創建一個目錄，用來存放rocketmq相關的東西
mkdir /usr/rocketmq
cd /usr/rocketmq
2、下載并解壓rocketmq

下載

wget https://archive.apache.org/dist/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip

解壓

unzip rocketmq-all-4.7.1-bin-release.zip

如果提示unzip: Command Not Found

通過yum命令安裝，如果已經安裝了，請忽略

yum install -y unzip zip

看到這一個檔案夾就完成了

然后進入rocketmq-all-4.7.1-bin-release檔案夾

cd rocketmq-all-4.7.1-bin-release

RocketMQ的東西都在這了

二、搭建NameServer

在啟動NameServer之前，強烈建議修改一下啟動時的jvm引數，因為默認的引數都比較大，為了避免記憶體不夠，建議修改小，當然，如果你的記憶體足夠大，可以忽略，

vi bin/runserver.sh

修改畫圈的這一行

 可以設定小一點

-server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=32m -XX:MaxMetaspaceSize=50m

啟動NameServer

修改完之后，執行如下命令就可以啟動NameServer了

nohup sh bin/mqnamesrv &

查看NameServer日志

tail -f ~/logs/rocketmqlogs/namesrv.log

如果看到如下的日志，就說明啟動成功了

 

關閉NameServer

sh bin/mqshutdown namesrv

三、搭建Broker

這里啟動單機版的Broker

修改jvm引數

跟啟動NameServer一樣，也建議去修改jvm引數

vi bin/runbroker.sh

將畫圈的地方設定小點，當然也別太小啊

 

 可以這樣設定

-server -Xms1g -Xmx1g -Xmn512m

修改Broker組態檔broker.conf

這里需要改一下Broker組態檔，需要指定NameServer的地址，因為需要Broker需要往NameServer注冊

vi conf/broker.conf

Broker組態檔

這里就能看出Broker的配置了，什么Broker集群的名稱啊，Broker的名稱啊，Broker的id啊，都跟前面說的對上了，

在檔案末尾追加地址

namesrvAddr = localhost:9876

因為NameServer跟Broker在同一臺機器，所以是localhost，NameServer埠默認的是9876，

不過這里我還建議再修改一處資訊，因為Broker向NameServer進行注冊的時候，帶過去的ip如果不指定就會自動獲取，但是自動獲取的有個坑，就是有可能你的電腦無法訪問到這個自動獲取的ip，所以我建議手動指定你的電腦可以訪問到的服務器ip，

我的虛擬機的ip是192.168.3.158，所以就指定為192.168.3.158，如下

brokerIP1 = 192.168.3.158
brokerIP2 = 192.168.3.158

開啟自動創建Topic

autoCreateTopicEnable = true

如果以上都配置的話，最終的組態檔應該如下，紅圈的為新加的

啟動Broker

nohup sh bin/mqbroker -c conf/broker.conf &

-c 引數就是指定組態檔

查看日志

tail -f ~/logs/rocketmqlogs/broker.log

當看到如下日志就說明啟動成功了

關閉Broker

sh bin/mqshutdown broker

查看Broker 與NameServer是否運行

jps

 說明Broker與NameServer是運行狀態

四、搭建可視化控制臺

其實前面NameServer和Broker搭建完成之后，就可以用來收發訊息了，但是為了更加直觀，可以搭一套可視化的服務，

可視化服務其實就是一個jar包，啟動就行了，

jar包可以從這獲取

鏈接：https://pan.baidu.com/s/16s1qwY2qzE2bxR81t5Wm6w
提取碼：s0sd

將jar包上傳到服務器，放到/usr/rocketmq的目錄底下，當然放哪都無所謂，這里只是為了方便，因為rocketmq的東西都在這里

然后進入/usr/rocketmq下，執行如下命名

nohup java -jar -server -Xms256m -Xmx256m -Drocketmq.config.namesrvAddr=localhost:9876 -Dserver.port=8088 rocketmq-console-ng-1.0.1.jar &

rocketmq.config.namesrvAddr就是用來指定NameServer的地址的

查看日志

tail -f ~/logs/consolelogs/rocketmq-console.log

當看到如下日志，就說明啟動成功了

然后在瀏覽器中輸入http://linux服務器的ip:8088/就可以看到控制臺了，如果無法訪問，可以看看防火墻有沒有關閉

 

通過控制臺可以查看生產者、消費者、Broker集群等資訊，非常直觀，

功能很多，這里就不一一介紹了，

停止命令

查看行程

1.jps

  • -q：只輸出行程 ID
  • -m：輸出傳入 main 方法的引數
  • -l：輸出完全的包名，應用主類名，jar的完全路徑名
  • -v：輸出jvm引數
  • -V：輸出通過flag檔案傳遞到JVM中的引數

2.ps aux | grep java 來獲取java行程 id

結束行程

kill pid 或者（kill -9 pid）

  • pid: jar包行程號
  • kill pid： 結束行程，有局限性，例如后臺行程，守護行程等，不能結束
  • kill - 9 pid ： 表示強制殺死該行程；

 

測驗

環境搭好之后，就可以進行測驗了，

引入依賴

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.7.1</version>
</dependency>

生產者發送訊息

    @Test
    public void sendTest() throws Exception{
        //創建一個生產者，指定生產者組為ldProducer
        DefaultMQProducer producer = new DefaultMQProducer("ldProducer");

        // 指定NameServer的地址
        producer.setNamesrvAddr("192.168.3.158:9876");
        // 第一次發送可能會超時，我設定的比較大
        producer.setSendMsgTimeout(60000);

        // 啟動生產者
        producer.start();

        // 創建一條訊息
        // topic為 ldTopic
        // 訊息內容為 java學習日記
        // tags 為 TagA
        Message msg = new Message("ldTopic", "TagA", "java學習日記 ".getBytes(RemotingHelper.DEFAULT_CHARSET));

        // 發送訊息并得到訊息的發送結果，然后列印
        SendResult sendResult = producer.send(msg);
        System.out.printf("%s%n", sendResult);

        // 關閉生產者
        producer.shutdown();
    }
  • 構建一個訊息生產者DefaultMQProducer實體，然后指定生產者組為ldProducer；
  • 指定NameServer的地址：服務器的ip:9876，因為需要從NameServer拉取Broker的資訊
  • producer.start() 啟動生產者
  • 構建一個內容為三友的java日記的訊息，然后指定這個訊息往ldTopic這個topic發送
  • producer.send(msg)：發送訊息，列印結果
  • 關閉生產者

消費者消費訊息

public class ConsumerMsg {
    public static void main(String[] args) throws Exception {
        // 通過push模式消費訊息，指定消費者組
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ldConsumer");
        consumer.setNamesrvAddr("192.168.3.158:9876");
        // 訂閱這個topic下的所有的訊息
        consumer.subscribe("ldTopic", "*");
        // 注冊一個消費的監聽器，當有訊息的時候，會回呼這個監聽器來消費訊息
        consumer.registerMessageListener(new MessageListenerConcurrently() {
            @Override
            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
                for (MessageExt msg : msgs) {
                    System.out.printf("消費訊息:%s", new String(msg.getBody()) + "\n");
                }

                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        });

        consumer.start();

        System.out.printf("Consumer Started.%n");
    }
}
  • 創建一個消費者實體物件，指定消費者組為ldConsumer
  • 指定NameServer的地址：服務器的ip:9876
  • 訂閱 ldTopic 這個topic的所有資訊
  • consumer.registerMessageListener ，這個很重要，是注冊一個監聽器，這個監聽器是當有訊息的時候就會回呼這個監聽器，處理訊息，所以需要用戶實作這個介面，然后處理訊息，
  • 啟動消費者

啟動之后，消費者就會消費剛才生產者發送的訊息，于是控制臺就列印出如下資訊

 

再去看控制臺，已消費

 

SpringBoot環境下集成RocketMQ

集成

在實際專案中肯定不會像上面測驗那樣用，都是集成SpringBoot的，

1、引入依賴

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.1.1</version>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <version>2.1.1.RELEASE</version>
</dependency>

2、yml配置

rocketmq:
  producer:
    group: ldProducer
  name-server: 192.168.3.158:9876

3、創建消費者

SpringBoot底下只需要實作RocketMQListener介面，然后加上@RocketMQMessageListener注解即可

@Component
@RocketMQMessageListener(consumerGroup = "ldConsumer", topic = "ldDelayTaskTopic")
@Slf4j
public class LdRocketMQListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String msg) {
        log.info("獲取到延遲任務訊息:{}",msg);
    }
}

@RocketMQMessageListener需要指定消費者屬于哪個消費者組，消費哪個topic，NameServer的地址已經通過yml組態檔配置類

4、測驗

@RestController
@Slf4j
public class RocketMQDelayTaskController {

    @Resource
    private DefaultMQProducer producer;

    @GetMapping("/rocketmq/add")
    public void addTask(@RequestParam("task") String task) throws Exception {
        Message msg = new Message("ldDelayTaskTopic", "TagA", task.getBytes(RemotingHelper.DEFAULT_CHARSET));
        msg.setDelayTimeLevel(2);
        // 發送訊息并得到訊息的發送結果，然后列印
        log.info("提交延遲任務");
        producer.send(msg);
    }

}

 

可能遇到的問題

搭完mq單主單從集群之后，美滋滋想發一下message, 沒想到碰到一個坑爹的問題：

Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 14  DESC: service not available now, maybe disk full, CL:  0.90 CQ:  0.90 INDEX:  0.90, maybe your broker machine memory too small.
org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [549]ms, Topic: ldTopicA, BrokersSent: [broker-a, broker-a, broker-a]
See http://rocketmq.apache.org/docs/faq/ for further details.

    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:665)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1343)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1289)
    at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:325)
    at com.example.delay.MQTest.sendTest(MQTest.java:46)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    ...
Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 14  DESC: service not available now, maybe disk full, CL:  0.90 CQ:  0.90 INDEX:  0.90, maybe your broker machine memory too small.
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:665)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:505)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:487)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:431)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:854)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:584)

看報錯應該是磁盤空間不足的問題，看到一個帖子https://bbs.csdn.net/topics/392568834，還挺符合的，雖然給出的解決方案說的沒那么詳細，但是值得一試，

查看磁盤空間

 

已用91%，查閱百度之后發現rocketmq原始碼的DefaultMessageStore類里，默認會把剩余磁盤的比率不足75%(rocketmq版本不同這個比率好像不一樣)當做磁盤空間不足處理，看來磁盤是有點不夠了，

先cd到rocketmq組態檔的路徑，我這里配置的是雙主雙從同步的模式，所以cd到組態檔（根據配置的不同檔案夾的路徑不一樣，但都在/conf下），

  1. cd rocketmq-all-4.7.1-bin-release/conf/2m-2s-sync/
  2. vim broker-a.properties
  3. 在最后加一行diskMaxUsedSpaceRatio=99(所有節點的組態檔都加一下)，表示剩余磁盤比例不足99才報錯

  4. :wq 保存退出

  5. 重啟mq

 重新發送訊息Ok了

 

 

作者：donleo123 出處：https://www.cnblogs.com/donleo123/ 本文如對您有幫助，還請多推薦下此文，如有錯誤歡迎指正，相互學習，共同進步，

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/548699.html

標籤：Java

上一篇：Linux 服務器大量的 log 日志，如何正確看日志快速定位錯誤？你必須學會！

下一篇：Java重寫toString的意義

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C＃(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 【C++】Microsoft C++、C 和匯編程式檔案

    ......

    uj5u.com 2020-09-10 00:57:23 more
  • 例外宣告

    相比于斷言適用于排除邏輯上不可能存在的狀態，例外通常是用于邏輯上可能發生的錯誤。 例外宣告 Item 1：當函式不可能拋出例外或不能接受拋出例外時，使用noexcept 理由 如果不打算拋出例外的話，程式就會認為無法處理這種錯誤，并且應當盡早終止，如此可以有效地阻止例外的傳播與擴散。 示例 //不可 ......

    uj5u.com 2020-09-10 00:57:27 more
  • Codeforces 1400E Clear the Multiset(貪心 + 分治)

    鏈接：https://codeforces.com/problemset/problem/1400/E 來源：Codeforces 思路：給你一個陣列，現在你可以進行兩種操作，操作1：將一段沒有 0 的區間進行減一的操作，操作2：將 i 位置上的元素歸零。最終問：將這個陣列的全部元素歸零后操作的最少 ......

    uj5u.com 2020-09-10 00:57:30 more
  • UVA11610 【Reverse Prime】

    本人看到此題沒有翻譯，就附帶了一個自己的翻譯版本 思考 這一題，它的第一個要求是找出所有 $7$ 位反向質數及其質因數的個數。 我們應該需要質數篩篩選1~$10^{7}$的所有數，這里就不慢慢介紹了。但是，重讀題，我們突然發現反向質數都是 $7$ 位，而將它反過來后的數字卻是 $6$ 位數，這就說明 ......

    uj5u.com 2020-09-10 00:57:36 more
  • 統計區間素數數量

    1 #pragma GCC optimize(2) 2 #include <bits/stdc++.h> 3 using namespace std; 4 bool isprime[1000000010]; 5 vector<int> prime; 6 inline int getlist(int ......

    uj5u.com 2020-09-10 00:57:47 more
  • C/C++編程筆記：C++中的 const 變數詳解，教你正確認識const用法

    1、C中的const 1、區域const變數存放在堆疊區中，會分配記憶體（也就是說可以通過地址間接修改變數的值）。測驗代碼如下： 運行結果： 2、全域const變數存放在只讀資料段（不能通過地址修改，會發生寫入錯誤）， 默認為外部聯編，可以給其他源檔案使用（需要用extern關鍵字修飾） 運行結果： ......

    uj5u.com 2020-09-10 00:58:04 more
  • 【C++犯錯記錄】VS2019 MFC添加資源不懂如何修改資源宏ID

    1. 首先在資源視圖中，添加資源 2. 點擊新添加的資源，復制自動生成的ID 3. 在解決方案資源管理器中找到Resource.h檔案，編輯，使用整個專案搜索和替換的方式快速替換 宏宣告 4. Ctrl+Shift+F 全域搜索，點擊查找全部，然后逐個替換 5. 為什么使用搜索替換而不使用屬性視窗直 ......

    uj5u.com 2020-09-10 00:59:11 more
  • 【C++犯錯記錄】VS2019 MFC不懂的批量添加資源

    1. 打開資源頭檔案Resource.h，在其中預先定義好宏 ID（不清楚其實ID值應該設定多少，可以先新建一個相同的資源項，再在這個資源的ID值的基礎上遞增即可） 2. 在資源視圖中選中專案資源，按F7編輯資源檔案，按 ID 型別 相對路徑的形式添加 資源。（別忘了先把檔案拷貝到專案中的res檔案 ......

    uj5u.com 2020-09-10 01:00:19 more
  • C/C++編程筆記：關于C++的參考型別，專供新手入門使用

    今天要講的是C++中我最喜歡的一個用法——參考，也叫別名。 參考就是給一個變數名取一個變數名，方便我們間接地使用這個變數。我們可以給一個變數創建N個參考，這N + 1個變數共享了同一塊記憶體區域。(參考型別的變數會占用記憶體空間，占用的記憶體空間的大小和指標型別的大小是相同的。雖然參考是一個物件的別名，但 ......

    uj5u.com 2020-09-10 01:00:22 more
  • 【C/C++編程筆記】從頭開始學習C ++：初學者完整指南

    眾所周知，C ++的學習曲線陡峭，但是花時間學習這種語言將為您的職業帶來奇跡，并使您與其他開發人員區分開。您會更輕松地學習新語言，形成真正的解決問題的技能，并在編程的基礎上打下堅實的基礎。 C ++將幫助您養成良好的編程習慣（即清晰一致的編碼風格，在撰寫代碼時注釋代碼，并限制類內部的可見性），并且由 ......

    uj5u.com 2020-09-10 01:00:41 more
最新发布
  • Rust中的智能指標:Box<T> Rc<T> Arc<T> Cell<T> RefCell<T> Weak

    Rust中的智能指標是什么 智能指標（smart pointers）是一類資料結構，是擁有資料所有權和額外功能的指標。是指標的進一步發展 指標（pointer）是一個包含記憶體地址的變數的通用概念。這個地址參考，或 ” 指向”（points at）一些其 他資料 。參考以 & 符號為標志并借用了他們所 ......

    uj5u.com 2023-04-20 07:24:10 more
  • Java的值傳遞和參考傳遞

    值傳遞不會改變本身，參考傳遞（如果傳遞的值需要實體化到堆里）如果發生修改了會改變本身。 1.基本資料型別都是值傳遞 package com.example.basic; public class Test { public static void main(String[] args) { int ......

    uj5u.com 2023-04-20 07:24:04 more
  • [2]SpinalHDL教程——Scala簡單入門

    第一個 Scala 程式 shell里面輸入 $ scala scala> 1 + 1 res0: Int = 2 scala> println("Hello World!") Hello World! 檔案形式 object HelloWorld { /* 這是我的第一個 Scala 程式 * 以 ......

    uj5u.com 2023-04-20 07:23:58 more
  • 理解函式指標和回呼函式

    理解 函式指標 指向函式的指標。比如： 理解函式指標的偽代碼 void (*p)(int type, char *data); // 定義一個函式指標p void func(int type, char *data); // 宣告一個函式func p = func; // 將指標p指向函式func ......

    uj5u.com 2023-04-20 07:23:52 more
  • Django筆記二十五之資料庫函式之日期函式

    本文首發于公眾號：Hunter后端 原文鏈接：Django筆記二十五之資料庫函式之日期函式 日期函式主要介紹兩個大類，Extract() 和 Trunc() Extract() 函式作用是提取日期，比如我們可以提取一個日期欄位的年份，月份，日等資料 Trunc() 的作用則是截取，比如 2022-0 ......

    uj5u.com 2023-04-20 07:23:45 more
  • 一天吃透JVM面試八股文

    什么是JVM？ JVM，全稱Java Virtual Machine（Java虛擬機），是通過在實際的計算機上仿真模擬各種計算機功能來實作的。由一套位元組碼指令集、一組暫存器、一個堆疊、一個垃圾回收堆和一個存盤方法域等組成。JVM屏蔽了與作業系統平臺相關的資訊，使得Java程式只需要生成在Java虛擬機 ......

    uj5u.com 2023-04-20 07:23:31 more
  • 使用Java接入小程式訂閱訊息！

    更新完微信服務號的模板訊息之后，我又趕緊把微信小程式的訂閱訊息給實作了！之前我一直以為微信小程式也是要企業才能申請，沒想到小程式個人就能申請。 訊息推送平臺🔥推送下發【郵件】【短信】【微信服務號】【微信小程式】【企業微信】【釘釘】等訊息型別。 https://gitee.com/zhongfuch ......

    uj5u.com 2023-04-20 07:22:59 more
  • java -- 緩沖流、轉換流、序列化流

    緩沖流 緩沖流, 也叫高效流, 按照資料型別分類： 位元組緩沖流：BufferedInputStream，BufferedOutputStream 字符緩沖流：BufferedReader，BufferedWriter 緩沖流的基本原理，是在創建流物件時，會創建一個內置的默認大小的緩沖區陣列，通過緩沖 ......

    uj5u.com 2023-04-20 07:22:49 more
  • Java-SpringBoot-Range請求頭設定實作視頻分段傳輸

    老實說，人太懶了，現在基本都不喜歡寫筆記了，但是網上有關Range請求頭的文章都太水了 下面是抄的一段StackOverflow的代碼...自己大修改過的，寫的注釋挺全的，應該直接看得懂，就不解釋了 寫的不好...只是希望能給視頻網站開發的新手一點點幫助吧. 業務場景：視頻分段傳輸、視頻多段傳輸（理 ......

    uj5u.com 2023-04-20 07:22:42 more
  • Windows 10開發教程_編程入門自學教程_菜鳥教程-免費教程分享

    教程簡介 Windows 10開發入門教程 - 從簡單的步驟了解Windows 10開發，從基本到高級概念，包括簡介，UWP，第一個應用程式，商店，XAML控制元件，資料系結，XAML性能，自適應設計，自適應UI，自適應代碼，檔案管理，SQLite資料庫，應用程式到應用程式通信，應用程式本地化，應用程式 ......

    uj5u.com 2023-04-20 07:22:35 more

Copyright © 2010-2020 有解無憂