TsgcWSPClient_MQTT › Events › OnMQTTConnect

OnMQTTConnect 事件

收到 CONNACK 后触发；报告 Session 标志、ReasonCode 和 MQTT 5 ConnectProperties。

语法

property OnMQTTConnect: TsgcWSMQTTConnectEvent;
// TsgcWSMQTTConnectEvent = procedure(Connection: TsgcWSConnection; const Session: Boolean; const ReasonCode: Integer; const ReasonName: String; const ConnectProperties: TsgcWSMQTTCONNACKProperties) of object

默认值

—

备注

当代理用 CONNACK 确认 CONNECT 时触发。这是 MQTT 会话完全可用的第一个时刻，可以安全地在此处理程序内调用 Subscribe/Publish。参数：

• Session — 代理端会话状态。CleanSession = True 时，代理必须以 Session = False 回应。CleanSession = False 时，Session = True 表示代理仍有该 ClientIdentifier 的存储状态，Session = False 表示没有。
• ReasonCode（MQTT 5）— CONNACK 的数字原因码（0 = 成功）。
• ReasonName（MQTT 5）— ReasonCode 的可读描述。
• ConnectProperties（MQTT 5）— broker 功能和协商后的限制：SessionExpiryInterval、ReceiveMaximum、MaximumQoS、RetainAvailable、MaximumPacketSize、AssignedClientIdentifier、TopicAliasMaximum、ReasonString、UserProperties、WildcardSubscriptionAvailable、SubscriptionIdentifiersAvailable、SharedSubscriptionAvailable、ResponseInformation、ServerReference、AuthenticationMethod 和 AuthenticationData。

示例

procedure TForm1.MQTTConnect(Connection: TsgcWSConnection;
  const Session: Boolean; const ReasonCode: Integer;
  const ReasonName: String;
  const ConnectProperties: TsgcWSMQTTCONNACKProperties);
begin
  if ReasonCode <> 0 then
  begin
    Memo1.Lines.Add('Connect rejected: ' + ReasonName);
    Exit;
  end;

  Memo1.Lines.Add(Format('Connected. Session=%s MaxQoS=%d',
    [BoolToStr(Session, True), ConnectProperties.MaximumQoS]));

  // now it is safe to subscribe and publish
  MQTT.Subscribe('sensors/#', mtqsAtLeastOnce);
end;

返回事件