Python 客戶端類庫之paho-mqtt學習總結

来源:https://www.cnblogs.com/shouke/p/18417803
-Advertisement-
Play Games

實踐環境 Python 3.9.13 paho-mqtt 2.1.0 簡介 Eclipse Paho MQTT Python客戶端類庫實現了MQTT 協議版本 5.0, 3.1.1, 和3.1。 該類庫提供一個客戶端類，允許應用連接到MQTT代理併發布消息，訂閱主題並檢索發佈的消息。同時還提供了一個 ...


實踐環境

Python 3.9.13

paho-mqtt 2.1.0

簡介

Eclipse Paho MQTT Python客戶端類庫實現了MQTT 協議版本 5.0, 3.1.1, 和3.1。

該類庫提供一個客戶端類，允許應用連接到MQTT代理併發布消息，訂閱主題並檢索發佈的消息。同時還提供了一個寫其它輔助函數，使向MQTT伺服器發佈一次性消息變得非常簡單。

支持 Python 3.7+。

MQTT協議是一種機器對機器(M2M)/“物聯網”連接協議。它被設計為一種極其輕量級的發佈/訂閱消息傳輸，對於需要小代碼占用和/或網路帶寬非常昂貴的遠程連接非常有用。

安裝

pip install paho-mqtt

已知限制

以下是已知的未實現的MQTT功能。

當clean_session為False時，會話僅存儲在記憶體中，不會持久化。這意味著當客戶端重新啟動時（不僅僅是重新連接，通常是因為程式重新啟動而重新創建對象），會話就會丟失。這可能會導致消息丟失。

客戶端會話的以下部分丟失：

  • 已從伺服器接收到但尚未完全確認的 QoS 2 消息。

    由於客戶端會盲目確認任何PUBCOMP（QoS 2 事務的最後一條消息），因此它不會掛起，但會丟失此 QoS 2 消息。

  • 已發送到伺服器但尚未完全確認的 QoS 1 和 QoS 2 消息。

    這意味著傳遞給 publish()的消息可能會丟失。這可以通過讓傳遞給 publish() 的所有消息都有相應的on_publish() 調用或使用wait_for_publish來緩解。

    這也意味著代理在會話中可能有 QoS2 消息。由於客戶端從一個空會話開始，它不知道它，並將重用mid。這還沒有解決。

此外，當clean_session為True時，此類庫將在網路重新連接時重新發佈 QoS > 0消息。這意味著 QoS > 0消息不會丟失。但標準規定，我們應該丟棄發送發佈包的任何消息。設置為True意味著不符合標準，QoS 2 可能會被接收兩次。

如果只需要一次交付的 QoS 2 保證，則應設置clean_session=False。

用法與API

API詳細線上文檔：https://eclipse.dev/paho/files/paho.mqtt.python/html/client.html

示例：https://github.com/eclipse/paho.mqtt.python/tree/master/examples

開始

下麵是一個非常簡單的示例，它訂閱代理$SYS主題樹並列印出結果消息：

# -*- coding:utf-8 -*-

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, reason_code, properties):
    '''客戶端從伺服器接收到 CONNACK 響應時的回調'''

    print(f"Connected with result code {reason_code}")  # 成功連接時 reason_code 值為 Success

    # 在on_connect()中執行訂閱操作，意味著如果應用失去連接並且重新連接後，訂閱將被續訂。
    if reason_code == 'Success':
        client.subscribe('$SYS/#')

def on_disconnect(client, userdata, flags, reason_code, properties):
    print(f'Disconnected with result code {reason_code}')


def on_message(client, userdata, msg):
    '''從伺服器收到 PUBLISH 消息時的回調。'''
    print(msg.topic + ' ' + str(msg.payload)) # 輸出值形如 $SYS/broker/version b'mosquitto version 2.0.18'

mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
mqttc.on_connect = on_connect
mqttc.on_disconnect = on_disconnect
mqttc.on_message = on_message
 
# client.username_pw_set('testacc', 'test1234') # 設置訪問賬號和密碼

mqttc.connect("mqtt.eclipseprojects.io", 1883, 60)

# 阻塞調用，處理網路流量、分派回調和處理重新連接
# 有其它提供線程介面和手動介面的loop*()函數可用
mqttc.loop_forever()

說明：

  1. Client.username_pw_set(username: str | None, password: str | None = None*) → None

    為代理身份驗證設置用戶名和密碼(可選)。

    必須在connect()之前調用才能生效。需要支持MQTT v3.1或更高版本的代理。

    • 參數：
      • username – 要進行身份驗證的用戶名。需要與客戶端id沒有關係。必須是字元串[MQTT-3.1.3-11]。設置為“None”可將客戶端重置為不使用用戶名/密碼進行代理身份驗證。
      • password – 用於身份驗證的密碼。可選，如果不需要，則設置為None。如果為字元串r，那麼它將被編碼為UTF-8。
  2. Client.connect(host: str, port: int = 1883, keepalive: int = 60, bind_address: str = '', bind_port: int = 0, clean_start: bool | Literal[3] = 3, properties: Properties|None = None) → MQTTErrorCode

    連接到遠程代理。這是一個阻塞調用，用於建立底層連接並傳輸CONNECT數據包。請註意，在收到並處理CONNACK之前，連接狀態不會更新（這需要一個正在運行的網路迴圈，請參閱loop_start, loop_forever, loop…)).
    參數：

    • host– 遠程代理的主機名或IP地址。

    • port– 要連接的伺服器主機的網路埠。預設為1883。請註意，SSL/TLS上MQTT的預設埠是8883，因此如果使用TLS_set()可能需要提供埠。

    • keepalive - 設置心跳的時間，單位是秒。這個值告訴MQTT客戶端，在沒有接收到任何通信的情況下，多久應該發送一個PING請求給伺服器，以保持連接，預設60秒。

    • clean_start -（僅限MQTT v5.0）True、False或MQTT_CLEAN_START_FIRST_ONLY。總是設置MQTT v5.0 clean_start標誌、從不或僅在第一次成功連接時。設置clean_start標誌後，MQTT會話數據（如未完成的消息和訂閱）在成功連接時被清除。對於MQTT v3.1.1，Client的clean_session參數應用於類似的結果。

    • properties (Properties) –( 僅僅限MQTT v5.0)需要在MQTT連接包發送的的MQTT v5.0 屬性。

客戶端(Client)

Client類一般使用流程如下：

  1. 創建客戶端實例
  2. 使用connect*() 函數之一連接到代理
  3. 調用其中一個loop*()函數來維護代理的網路流量
  4. 使用subscribe()訂閱主題並接收消息
  5. 使用publish()將消息發佈到代理
  6. 使用disconnect()斷開與代理的連接

將調用回調以允許應用程式根據需要處理事件。這些回調如下所述。

網路迴圈

這些功能是Client背後的驅動力。如果它們沒有被調用，傳入的網路數據將不會被處理，傳出的網路數據也不會被髮送。管理網路環路有四種選擇。這裡描述了三個，第四個在下麵的“外部事件迴圈支持”中描述。不要混合使用不同的loop函數。

loop_start() / loop_stop()
mqttc.loop_start()

while True:
    temperature = sensor.blocking_read()
    mqttc.publish("paho/temperature", temperature)

mqttc.loop_stop()

這些函數實現了網路迴圈的線程介面。在connect*()之前或之後調用loop_start()一次，會在後臺運行一個線程來自動調用loop()。這釋放了主線程，用於可能阻塞的其他工作。此調用還處理與代理的重新連接。調用loop_stop() 以停止後臺線程。如果調用disconnect()，迴圈也會停止。

loop_forever()
mqttc.loop_forever(retry_first_connection=False)

這是網路迴圈的阻塞形式，在客戶端調用disconnect()之前不會返回(即調用mqttc.disconnect()後會停止阻塞，繼續運行其後的代碼)。它會自動處理重新連接。
除了使用connect_async時的第一次連接嘗試外，使用retry_first_connection=True 使其重試第一次連接。
警告：這可能會導致客戶端保持連接到不存在的主機而不會出現失敗。

loop()
run = True
while run:
    rc = mqttc.loop(timeout=1.0)
    if rc != 0:
        # need to handle error, possible reconnecting or stopping the application

定期調用以處理網路事件。此調用觸發select()等待，直到網路套接字可用於讀取或寫入，如果套接字可用，則處理流入/流出的數據。此函數最多阻塞timeout秒。timeout不能超過客戶端的keepalive值，否則代理會定期斷開客戶端的連接。
使用這種迴圈，需要自己處理重新連接策略。

回調

與paho-mqtt交互的介面包括各種回調，當發生某些事件時，類庫會調用這些回調。

回調是在代碼中定義的函數，用於實現對這些事件要求的操作。這可能只是列印收到的消息，也可能是更複雜的行為。

回調API是有版本的，所選版本是我們提供給客戶端構造函數的CallbackAPIVersion。目前支持兩個版本：

  • CallbackAPIVersion.VERSION1：這是paho-mqtt 2.0版本之前使用的歷史版本。它是在引入CallbackAPIVersion之前使用的API。此版本已棄用，將在paho-mqtt 3.0版本中刪除。
  • CallbackAPIVersion.VERSION2：此版本在協議MQTT 3.x和MQTT 5.x之間更為一致。它也更適用於MQTT 5.x，因為reason_code和屬性始終在可獲取時提供。建議所有用戶升級到此版本。強烈建議MQTT 5.x用戶使用。

存在以下回調：

  • on_connec()：當收到代理返回CONNACK時被調用。調用可能是針對被拒絕的連接，請檢查reason_code以查看連接是成功還是被拒絕。
  • on_connect_fail()：當TCP連接建立失敗時，由loop_forever()和loop_start()調用。當直接使用connect()或reconnect()時，不會調用此回調。它僅由loop_start()和loop_forever()製造的自動（重新）連接後被調用
  • on_disconnect()：當連接關閉時被調用。
  • on_message()：收到代理返回的MQTT消息時被調用。
  • on_publish()：當MQTT消息發送到代理時被調用。取決於QoS級別，回調在不同時刻被調用：
    • 對於QoS==0，一旦消息通過網路發送，就會調用它。這可能是在相應的publish()返回之前。
    • 對於QoS==1，當收到代理返回的對應消息的PUBACK時調用它
    • 對於QoS==2，當收到代理返回的對應消息的PUBCOMP時，會調用它
  • on_subscribe()：當收到代理返回的SUBACK時被調用
  • on_unsubscribe：當收到代理返回的UNSUBACK時被調用
  • on_log()：當類庫記錄一條消息時被調用
  • onSocket_open、onSocket_close、onSocket_register_write、onSocket_unregister_write：用於外部迴圈支持(External event loop support)的回調。詳見下文。

參閱線上文檔查看有關每個回調的特征。

訂閱示例
# -*- coding:utf-8 -*-

import paho.mqtt.client as mqtt

def on_subscribe(client, userdata, mid, reason_code_list, properties):
    # 由於我們只訂閱了一個通道，reason_code_list只包含一個條目
    # print(reason_code_list) #輸出： [ReasonCode(Suback, 'Granted QoS 0')]
    if reason_code_list[0].is_failure:
        print(f"Broker rejected you subscription: {reason_code_list[0]}")
    else:
        print(f"Broker granted the following QoS: {reason_code_list[0].value}")

def on_unsubscribe(client, userdata, mid, reason_code_list, properties):
    #註意，reason_code_list僅存在於MQTTv5中，在MQTTv3中，它將始終為空
    if len(reason_code_list) == 0 or not reason_code_list[0].is_failure:
        print("unsubscribe succeeded (if SUBACK is received in MQTTv3 it success)")
    else:
        print(f"Broker replied with failure: {reason_code_list[0]}")
    client.disconnect()

def on_message(client, userdata, message):
    # userdata是我們選擇提供的數據結構，這裡為一個列表(通過下方的 mqttc.user_data_set([])設置，該函數參數即為userdata參數值
    userdata.append(message.payload)
    # 假設只想處理10條消息
    if len(userdata) >= 10:
        client.unsubscribe("$SYS/#")

def on_connect(client, userdata, flags, reason_code, properties):
    if reason_code.is_failure:
        print(f"Failed to connect: {reason_code}. loop_forever() will retry connection")
    else:
        # 應該始終在 on_connect 回調中訂閱以確保在重新連接時訂閱依舊存在。
        client.subscribe("$SYS/#")

mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
mqttc.on_connect = on_connect
mqttc.on_message = on_message
mqttc.on_subscribe = on_subscribe
mqttc.on_unsubscribe = on_unsubscribe

mqttc.user_data_set([]) # 設置 userdata
mqttc.connect("mqtt.eclipseprojects.io")
mqttc.loop_forever() # 當調用client.disconnect()後繼續執行以下代碼

print(f"Received the following message: {mqttc.user_data_get()}")
發佈示例
# -*- coding:utf-8 -*-

import time
import paho.mqtt.client as mqtt

def on_publish(client, userdata, mid, reason_code, properties):
    '''reason_code和properties將僅出現在MQTTv5中。在MQTTv3中始終未設置
    使用不存在`uncaked_publish`中的`mid`調用`on_publish()`。這是由於不可避免的競爭情形：
    * publish() 返回已發送消息的mid。
    * 主線程將publish()返回的mid添加到uncaked_publish中
    * loop_start線程調用on_publish()
    雖然不太可能（因為on_publish()將在網路往返後調用），但是這是一種可能發生的競爭情形
    避免競爭情形的最佳解決方案是使用publish()中的msg_info。還可以嘗試使用已確認的mid列表，而不是從待處理列表中刪除
    但是請記住，mid可以重覆使用！
    reason_code和properties將僅出現在MQTTv5中。在MQTTv3中始終未設置
    '''
    try:
        userdata.remove(mid)
    except KeyError:
        print("on_publish() is called with a mid not present in unacked_publish")
        print("This is due to an unavoidable race-condition:")
        print("* publish() return the mid of the message sent.")
        print("* mid from publish() is added to unacked_publish by the main thread")
        print("* on_publish() is called by the loop_start thread")
        print("While unlikely (because on_publish() will be called after a network round-trip),")
        print(" this is a race-condition that COULD happen")
        print("")
        print("The best solution to avoid race-condition is using the msg_info from publish()")
        print("We could also try using a list of acknowledged mid rather than removing from pending list,")
        print("but remember that mid could be re-used !")

unacked_publish = set()
mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
mqttc.on_publish = on_publish

mqttc.user_data_set(unacked_publish)
mqttc.connect("mqtt.eclipseprojects.io")
mqttc.loop_start()

# 應用生產一些消息
msg_info = mqttc.publish("paho/test/topic", "my message", qos=1)
unacked_publish.add(msg_info.mid)

msg_info2 = mqttc.publish("paho/test/topic", "my message2", qos=1)
unacked_publish.add(msg_info2.mid)

# 等待所有消息被髮布
while len(unacked_publish):
    time.sleep(0.1)

# 由於上述描述的競爭狀態, 以下等待所有消息發佈完成的方式更安全
msg_info.wait_for_publish()
msg_info2.wait_for_publish()

mqttc.disconnect()
mqttc.loop_stop()

說明：

  1. Client.max_inflight_messages_set(inflight: int) → None

    設置一次可以通過其網路流的QoS>0的消息的最大數量(可以簡單理解為允許多大數量的QoS>0的消息被同時進行傳輸處理)。預設值為20。

  2. Client.max_queued_messages_set（queue_size:int）→ Client
    設置傳出消息隊列中的最大消息數量。0表示無限制。

  3. MQTTMessageInfo.wait_for_publish(timeout: float | None = None) → None

    阻塞，直到與此對象關聯的消息被髮布，或者直到超時發生。如果timeout為None，則永遠不會超時。將超時設置為正數秒，例如1，2，以啟用超時。
    拋出：

    • ValueError–如果消息因傳出隊列已滿而未排隊。
    • RuntimeError-如果消息因其他原因未發佈。

  4. 實踐過程中發現，採用多線程併發發佈消息時，如果伺服器因為限流的原因不返回消息確認，那麼運行一小段時間後，出現消息無法發佈成功的情況(不報錯，但是消息無法抵達broker)，通過合理的參數調用以上三個函數，可以緩解這個問題。

Logger

客戶端會發出一些日誌消息，這些消息在故障排除過程中可能很有用。啟用日誌最簡單的方法是調用enable_logger()。可以提供自定義記錄器或使用預設記錄器

示例:

import logging
import paho.mqtt.client as mqtt

logging.basicConfig(level=logging.DEBUG)

mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
mqttc.enable_logger()

mqttc.connect("mqtt.eclipseprojects.io", 1883, 60)
mqttc.loop_start()

# Do additional action needed, publish, subscribe, ...
[...]

還可以定義一個on_log回調，它將接收所有日誌消息的副本。例子：

import paho.mqtt.client as mqtt

def on_log(client, userdata, paho_log_level, messages):
    if paho_log_level == mqtt.LogLevel.MQTT_LOG_ERR:
        print(message)

mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
mqttc.on_log = on_log

mqttc.connect("mqtt.eclipseprojects.io", 1883, 60)
mqttc.loop_start()

# Do additional action needed, publish, subscribe, ...
[...]

Paho日誌級別和標準日誌級別的對應關係如下：

Paho logging
MQTT_LOG_ERR logging.ERROR
MQTT_LOG_WARNING logging.WARNING
MQTT_LOG_NOTICE logging.INFO (no direct equivalent)
MQTT_LOG_INFO logging.INFO
MQTT_LOG_DEBUG logging.DEBUG

外部事件迴圈支持

為了支持其他網路迴圈，如asyncio（參見示例)，類庫公開了一些方法和回調來支持這些用例。

存在以下迴圈方法：

  • loop_read：應該在套接字可讀取時調用。
  • loop_write：應該在套接字可寫並且類庫需要寫入數據時調用。
  • loop_misc：應每隔幾秒鐘調用一次，以處理消息重試和ping。

用偽代碼表示如下:

while run:
    if need_read:
        mqttc.loop_read()
    if need_write:
        mqttc.loop_write()
    mqttc.loop_misc()

    if not need_read and not need_write:
        # But don't wait more than few seconds, loop_misc() need to be called regularly
        wait_for_change_in_need_read_or_write()
    updated_need_read_and_write()

棘手的部分是實現updated_need_read_and_write並等待條件變更。為了支持這一點，存在以下方法：

  • socket：當TCP連接打開時返回socket對象。此調用對於基於select迴圈特別有用。請參閱examples/loop_select.py 。

  • want_write()：如果有數據等待寫入，則返回True。這接近於上述偽代碼的need_writew，但還是應該檢查套接字是否可寫。

  • 回調函數on_socket_*：

    • on_socket_open：在套接字打開時調用。
    • on_socket_open：在套接字打開時調用。
    • on_socket_close：當套接字即將關閉時調用。
    • on_socket_register_write：當客戶端想要在套接字上寫入數據時調用
    • on_socket_unregister_write：當套接字上沒有更多數據要寫入時調用。

    回調對於事件迴圈特別有用，在事件迴圈中，可以註冊或註銷用於讀寫的套接字。請參閱examples/loop_asyncio.py 獲取示例。

回調總是按以下順序調用：

  • on_socket_open

  • 0或者更多次：

    • on_socket_register_write
    • on_socket_unregister_write

  • on_socket_close

全局輔助函數

客戶端模塊還提供了一些全局輔助函數。

topic_matches_sub(sub, topic)可用於檢查主題(topic)是否與訂閱(subscription)匹配。
例如：

主題foo/bar 將與訂閱foo/#或+/bar匹配
主題non/matching 將不匹配訂閱non/+/+

發佈

此模塊提供了兩個輔助函數single()和multiple()，允許以一次性方式直接發佈消息。換句話說，它們對於有一個/多個消息要發佈到代理，然後斷開連接而不需要其他任何東西的情況非常有用。

提供的兩個函數是single()和multiple()。

這兩個函數都支持MQTT v5.0，但目前不允許在連接或發送消息時設置任何屬性。

Single

發佈一條消息到代理，然後徹底斷開連接。

例子：

import paho.mqtt.publish as publish

publish.single("paho/test/topic", "payload", hostname="mqtt.eclipseprojects.io")

Multiple

發佈多條消息到代理，然後徹底斷開連接。

例子：

from paho.mqtt.enums import MQTTProtocolVersion
import paho.mqtt.publish as publish

msgs = [{'topic':"paho/test/topic", 'payload':"multiple 1"},
    ("paho/test/topic", "multiple 2", 0, False)]
publish.multiple(msgs, hostname="mqtt.eclipseprojects.io", protocol=MQTTProtocolVersion.MQTTv5)

訂閱

此模塊提供了兩個輔助函數simple()和callback()，以允許直接訂閱和處理消息。

這兩個函數都支持MQTT v5.0，但目前不允許在連接或發送消息時設置任何屬性。

Simple

訂閱一組主題並返回收到的消息。這是一個阻塞函數。
例子：

import paho.mqtt.subscribe as subscribe

msg = subscribe.simple("paho/test/topic", hostname="mqtt.eclipseprojects.io")
print("%s %s" % (msg.topic, msg.payload))

使用回調(Callback)

訂閱一組主題，並使用用戶提供的回調處理收到的消息。

例子：

import paho.mqtt.subscribe as subscribe

def on_message_print(client, userdata, message):
    print("%s %s" % (message.topic, message.payload))
    userdata["message_count"] += 1
    if userdata["message_count"] >= 5:
        # it's possible to stop the program by disconnecting
        client.disconnect()

subscribe.callback(on_message_print, "paho/test/topic", hostname="mqtt.eclipseprojects.io", userdata={"message_count": 0})

參考連接

https://github.com/eclipse/paho.mqtt.python

https://eclipse.dev/paho/files/paho.mqtt.python/html/client.html

作者：授客
微信/QQ：1033553122
全國軟體測試QQ交流群：7156436
Git地址：https://gitee.com/ishouke
友情提示：限於時間倉促，文中可能存在錯誤，歡迎指正、評論！
作者五行缺錢，如果覺得文章對您有幫助，請掃描下邊的二維碼打賞作者，金額隨意，您的支持將是我繼續創作的源動力，打賞後如有任何疑問，請聯繫我!!!
           微信打賞                        支付寶打賞                  全國軟體測試交流QQ群  
              


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 阿裡面試讓聊一聊Redis 的記憶體淘汰（驅逐）策略
    大家好，我是 V 哥，粉絲小A面試阿裡，說被問到 Redis 的記憶體淘汰策略的問題，整理這個筆記給他參考，也分享給大家，如果你遇到這個問題，會怎麼回答呢？ Redis 的記憶體淘汰策略是指當Redis的記憶體使用量達到設定的上限時，決定哪些數據應該被移除以便為新數據騰出空間的規則。Redis 提供了多種 ...
  • SpringBoot 初始化資源
    正文 跟靈分別後，我在椅子上發了很久的呆。可能有五分鐘吧。就這樣感受著微風吹過身體，聽著身邊熙熙攘攘的聲音。 我不知道為什麼要發呆。自然而然就這樣做了。 過了很久，我意識到可能必須要吃飯了，才起身找飯館。 今天情緒不太好。我不知道是不是因為沒睡夠。不過，並沒有從一開始就很糟糕，到晚上才開始。 先是發 ...
  • 騰訊又開發一款新工具，用起來真優雅！
    UGit 是一款為騰訊內部研發環境特點而定製的 Git 客戶端，旨在提高開發效率和團隊協作的流暢性。UGit 支持 macOS 10.11+、Apple Silicon 和 Win64 位系統。 官方地址：https://ugit.qq.com/zh/index.html 主要特性 Ugit 提供便 ...
  • JAVA類型轉換怎麼變
    類型轉換 類型轉換是將一個值從一種類型更改為另一種類型的過程。例如， 可以將String類型的數據“457”轉換為數值型，也可以將任意類型的 數據轉換為String類型。 如果從低精度數據類型向高精度數據類型轉換，則永遠不會溢出， 並且總是成功的；而把高精度數據類型向低精度數據類型轉換時，則會 有信 ...
  • 函數支持，Fast Request 2024.1.7 發佈
    本文梳理總結了一些 Java 互聯網項目中常見的 Redis 緩存應用場景，例如常見的 String 類型 Key-Value、對時效性要求高的場景、Hash 結構的場景以及對實時性要求高的場景等，全面涵蓋了 Redis 中所有的 5 種基本類型。 ...
  • 全網最適合入門的面向對象編程教程：51 Python 函數方法與介面-使用 Zope 實現介面
    在 Python 中，Zope 提供了一種機制來定義和實現介面。Zope 的介面模塊通常用於創建可重用的組件，並確保組件遵循特定的介面規範。 ...
  • MySQL 必知概念
    Delete、Drop 和 Truncate delete、truncate 僅僅刪除表裡面的數據，drop會把表的結構也刪除 delete 是 DML 語句，操作完成後，可以回滾，truncate 和 drop 是 DDL 語句，刪除之後立即生效，不能回滾 執行效率：drop > truncate ...
  • 華科python與人工智慧實踐（公選）教程
    python基礎 軟體下載 1.python下載安裝 點擊此鏈接進入官網windows下載地址 點擊箭頭處鏈接下載最新版本,進入頁面後下拉 根據你的機器下載對應版本，一般人使用的是X86架構windos系統，下載箭頭所指即可 若是不知道CPU架構，可見查看cpu架構，x86還是arm 下載後根據指引 ...
一周排行
    -Advertisement-
    Play Games
  • C# + WPF 音頻播放器 界面優雅，體驗良好
    前言 本文介紹一款使用 C# 與 WPF 開發的音頻播放器，其界面簡潔大方，操作體驗流暢。該播放器支持多種音頻格式（如 MP4、WMA、OGG、FLAC 等），並具備標記、實時歌詞顯示等功能。 另外，還支持換膚及多語言（中英文）切換。核心音頻處理採用 FFmpeg 組件，獲得了廣泛認可，目前 Git ...
  • OAuth2.0授權-gitee授權碼模式
    OAuth2.0授權驗證-gitee授權碼模式 本文主要介紹如何筆者自己是如何使用gitee提供的OAuth2.0協議完成授權驗證並登錄到自己的系統，完整模式如圖 1、創建應用 打開gitee個人中心->第三方應用->創建應用 創建應用後在我的應用界面，查看已創建應用的Client ID和Clien ...
  • FastReport.OpenSource .Net下開源免費報表列印組件
    解決了這個問題：《winForm下，fastReport.net 從.net framework 升級到.net5遇到的錯誤“Operation is not supported on this platform.”》 本文內容轉載自：https://www.fcnsoft.com/Home/Sho ...
  • 如何在 ASP.NET Core Web API 方法執行前後 “偷偷“ 作一些 “壞“ 事？初識 ActionFilterAttribute
    國內文章 WPF 從裸 Win 32 的 WM_Pointer 消息獲取觸摸點繪製筆跡 https://www.cnblogs.com/lindexi/p/18390983 本文將告訴大家如何在 WPF 裡面，接收裸 Win 32 的 WM_Pointer 消息，從消息裡面獲取觸摸點信息，使用觸摸點 ...
  • 在 ASP.NET Core Web API 中使用異常篩選器捕獲和統一處理異常
    前言 給大家推薦一個專為新零售快消行業打造了一套高效的進銷存管理系統。 系統不僅具備強大的庫存管理功能，還集成了高性能的輕量級 POS 解決方案，確保頁面載入速度極快，提供良好的用戶體驗。 項目介紹 Dorisoy.POS 是一款基於 .NET 7 和 Angular 4 開發的新零售快消進銷存管理 ...
  • AbpHelper CLI積累與實戰分享
    ABP CLI常用的代碼分享 一、確保環境配置正確 安裝.NET CLI： ABP CLI是基於.NET Core或.NET 5/6/7等更高版本構建的，因此首先需要在你的開發環境中安裝.NET CLI。這可以通過訪問Microsoft官網下載並安裝相應版本的.NET SDK來實現。 安裝ABP ...
  • 記一次HttpClient使用問題分析
    問題 問題是這樣的：第三方的webapi，需要先調用登陸介面獲取Cookie，訪問其它介面時攜帶Cookie信息。 但使用HttpClient類調用登陸介面，返回的Headers中沒有找到Cookie信息。 分析 首先，使用Postman測試該登陸介面，正常返回Cookie信息，說明是HttpCli ...
  • .NET周刊【9月第3期 2024-09-15】
    國內文章 關於.NET在中國為什麼工資低的分析 https://www.cnblogs.com/thinkingmore/p/18406244 .NET在中國開發者的薪資偏低，主要因市場需求、技術棧選擇和企業文化等因素所致。歷史上，.NET曾因微軟的閉源策略發展受限，儘管後來推出了跨平臺的.NET ...
  • 我的網站集成ElasticSearch初體驗
    在WPF開發應用中，動畫不僅可以引起用戶的註意與興趣，而且還使軟體更加便於使用。前面幾篇文章講解了畫筆（Brush），形狀（Shape），幾何圖形（Geometry），變換（Transform）等相關內容，今天繼續講解動畫相關內容和知識點，僅供學習分享使用，如有不足之處，還請指正。 ...
  • 第23篇 委托的概述
    什麼是委托？ 委托可以說是把一個方法代入另一個方法執行，相當於指向函數的指針；事件就相當於保存委托的數組； 1.實例化委托的方式： 方式1：通過new創建實例： public delegate void ShowDelegate(); 或者 public delegate string ShowDe ...
所有分類