feat(quic): disable datagram for now

- QUIC example connects to broker.emqx.io
- Disable datagram by default
- Support static linking

Author: qzhuyan

Cargo.toml

@@ -33,7 +33,7 @@ rustls-native-certs = { version = "0.7", optional = true }
 rustls-pki-types = { version = "1", optional = true }
 
 [features]
-default = ["strict-protocol-compliance", "tls"]
+default = ["strict-protocol-compliance"]
 # TLS/SSL transport support
 tls = ["dep:tokio-native-tls", "dep:native-tls"]
 # QUIC transport support
@@ -44,3 +44,8 @@ strict-protocol-compliance = []
 protocol-testing = []
 
 
+
+# Force static linking of the C runtime
+[profile.release.build-override]
+[target.aarch64-unknown-linux-musl]
+rustflags = ["-C", "target-feature=+crt-static"]

examples/tokio_async_mqtt_quic_example.rs

@@ -145,7 +145,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     // Configure MQTT client options with quic:// scheme
     let mqtt_options = MqttClientOptions::builder()
-        .peer("quic://192.168.64.17:14567") // Use quic:// scheme
+        .peer("quic://broker.emqx.io:14567") // Use quic:// scheme
         .client_id("tokio_quic_example_client")
         .keep_alive(60)
         .clean_start(true)
@@ -160,6 +160,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         // QUIC-specific configuration
         .quic_insecure_skip_verify(true) // ⚠️ For testing only! Use proper certs in production
         .quic_enable_0rtt(false) // Disable 0-RTT for security
+        .quic_datagram_receive_buffer_size(0) // disable datagram
         // For production with custom CA:
         // let ca_pem = std::fs::read_to_string("ca.pem").unwrap();
         // .quic_custom_root_ca_pem(ca_pem)

src/mqtt_client/tokio_async_client.rs

@@ -1061,6 +1061,10 @@ pub struct TokioAsyncClientConfig {
     /// Only used when connecting via quic:// URLs (requires `quic` feature)
     #[cfg(feature = "quic")]
     pub quic_client_key_pem: Option<String>,
+    /// QUIC transport: Datagram receive buffer size in bytes (0 = disable datagrams)
+    /// Only used when connecting via quic:// URLs (requires `quic` feature)
+    #[cfg(feature = "quic")]
+    pub quic_datagram_receive_buffer_size: usize,
 }
 
 impl Default for TokioAsyncClientConfig {
@@ -1095,6 +1099,8 @@ impl Default for TokioAsyncClientConfig {
             quic_client_cert_pem: None, // No client cert by default
             #[cfg(feature = "quic")]
             quic_client_key_pem: None, // No client key by default
+            #[cfg(feature = "quic")]
+            quic_datagram_receive_buffer_size: 0, // Disable datagram
         }
     }
 }
@@ -1557,6 +1563,12 @@ impl ConfigBuilder {
         self.config.quic_client_key_pem = Some(pem);
         self
     }
+
+    #[cfg(feature = "quic")]
+    pub fn quic_datagram_receive_buffer_size(mut self, size: usize) -> Self {
+        self.config.quic_datagram_receive_buffer_size = size;
+        self
+    }
 }
 
 impl Default for ConfigBuilder {
@@ -3002,6 +3014,11 @@ impl TokioClientWorker {
                         })?;
                 }
 
+                if &self.config.quic_datagram_receive_buffer_size > &0 {
+                    builder = builder.datagram_receive_buffer_size(
+                        self.config.quic_datagram_receive_buffer_size,
+                    );
+                }
                 let cfg = builder.build();
 
                 let transport = QuicTransport::connect_with_config(addr, cfg)

src/mqtt_client/transport/quic.rs

@@ -89,6 +89,7 @@ mod imp {
         pub client_private_key: Option<Vec<u8>>,
         /// ⚠️ DANGEROUS: Skip TLS certificate verification (for testing only!)
         pub insecure_skip_verify: bool,
+        pub datagram_receive_buffer_size: usize,
     }
 
     /// Builder for `QuicConfig` to simplify ergonomic construction.
@@ -99,6 +100,7 @@ mod imp {
         client_cert_chain: Option<Vec<Vec<u8>>>,
         client_private_key: Option<Vec<u8>>,
         insecure_skip_verify: bool,
+        datagram_receive_buffer_size: usize,
     }
 
     impl QuicConfigBuilder {
@@ -210,6 +212,11 @@ mod imp {
             Ok(self)
         }
 
+        pub fn datagram_receive_buffer_size(mut self, size: usize) -> Self {
+            self.datagram_receive_buffer_size = size;
+            self
+        }
+
         /// Provide a client private key for mutual TLS (DER-encoded bytes)
         pub fn client_private_key(mut self, key: Vec<u8>) -> Self {
             self.client_private_key = Some(key);
@@ -273,6 +280,7 @@ mod imp {
                 client_cert_chain: self.client_cert_chain,
                 client_private_key: self.client_private_key,
                 insecure_skip_verify: self.insecure_skip_verify,
+                datagram_receive_buffer_size: self.datagram_receive_buffer_size,
             }
         }
     }
@@ -287,6 +295,7 @@ mod imp {
                 client_cert_chain: None,
                 client_private_key: None,
                 insecure_skip_verify: false,
+                datagram_receive_buffer_size: 0,
             }
         }
     }
@@ -418,7 +427,10 @@ mod imp {
                     }
                 };
 
-            let quinn_crypto = ClientConfig::new(Arc::new(quic_client_cfg));
+            let mut quinn_crypto = ClientConfig::new(Arc::new(quic_client_cfg));
+            let mut trpt_cfg = quinn::TransportConfig::default();
+            trpt_cfg.datagram_receive_buffer_size(Some(cfg.datagram_receive_buffer_size));
+            quinn_crypto.transport_config(Arc::new(trpt_cfg));
 
             // Create an endpoint bound to an ephemeral UDP port
             let mut endpoint = Endpoint::client("0.0.0.0:0".parse().unwrap()).map_err(|e| {