Netty MQTT Client

License	The Apache License, Version 2.0
Categories	Net CLI User Interface Netty Networking
GroupId	org.jetlinks
ArtifactId	netty-mqtt-client
Last Version	1.0.0
Release Date	May 29, 2019
Type	jar
Description	Netty MQTT Client Netty MQTT Client
Project URL	https://github.com/jetlinks/netty-mqtt-client
Source Code Management	https://github.com/jetlinks/netty-mqtt-client

Download netty-mqtt-client

Filename	Size
netty-mqtt-client-1.0.0.pom
netty-mqtt-client-1.0.0.jar	41 KB
netty-mqtt-client-1.0.0-sources.jar	18 KB
netty-mqtt-client-1.0.0-javadoc.jar	66 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/org.jetlinks/netty-mqtt-client/ -->
<dependency>
    <groupId>org.jetlinks</groupId>
    <artifactId>netty-mqtt-client</artifactId>
    <version>1.0.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/org.jetlinks/netty-mqtt-client/
implementation 'org.jetlinks:netty-mqtt-client:1.0.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/org.jetlinks/netty-mqtt-client/
implementation ("org.jetlinks:netty-mqtt-client:1.0.0")

Apache Buildr

'org.jetlinks:netty-mqtt-client:jar:1.0.0'

Apache Ivy

<dependency org="org.jetlinks" name="netty-mqtt-client" rev="1.0.0">
  <artifact name="netty-mqtt-client" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='org.jetlinks', module='netty-mqtt-client', version='1.0.0')
)

Scala SBT

libraryDependencies += "org.jetlinks" % "netty-mqtt-client" % "1.0.0"

Leiningen

[org.jetlinks/netty-mqtt-client "1.0.0"]

Dependencies

compile (4)

Group / Artifact	Type	Version
io.netty : netty-codec-mqtt	jar	4.1.32.Final
io.netty : netty-handler	jar	4.1.32.Final
io.netty : netty-transport-native-epoll	jar	4.1.32.Final
com.google.guava : guava	jar	21.0

test (1)

Group / Artifact	Type	Version
junit : junit	jar	4.12

Project Modules

There are no modules declared in this project.

netty-mqtt-client

EventLoopGroup loop = new NioEventLoopGroup();
MqttClient mqttClient = new MqttClientImpl(((topic, payload) -> {
    System.out.println(topic + "=>" + payload.toString(StandardCharsets.UTF_8));
}));
mqttClient.setEventLoop(loop);
mqttClient.getClientConfig().setClientId("{clientId}");
mqttClient.getClientConfig().setUsername("{username}");
mqttClient.getClientConfig().setPassword("{password}");
mqttClient.getClientConfig().setProtocolVersion(MqttVersion.MQTT_3_1_1);
mqttClient.getClientConfig().setReconnect(true);
mqttClient.setCallback(new MqttClientCallback() {
    @Override
    public void connectionLost(Throwable cause) {
        cause.printStackTrace();
    }

    @Override
    public void onSuccessfulReconnect() {

    }
});
MqttConnectResult result = mqttClient.connect("127.0.0.1", 1883).await().get();
if (result.getReturnCode() != MqttConnectReturnCode.CONNECTION_ACCEPTED) {
    System.out.println("error:" + result.getReturnCode());
    mqttClient.disconnect();
} else {
    System.out.println("success");
//    mqttClient.publish("test", Unpooled.copiedBuffer("{\"type\":\"event\"}", StandardCharsets.UTF_8));
}

JetLinks IoT Platform

JetLinks 开源物联网平台社区

Versions

Version
1.0.0 May 29, 2019