/**********************************************
* DevCon5 GmbH, info@devcon5.ch
* Temperatur und Druck von BMP280 lesen
* und über MQTT veröffentlichen
  **********************************************/

#include <Wire.h>
#include <SPI.h>
#include <Adafruit_Sensor.h>
#include <Adafruit_BMP280.h>
#include <ESP8266WiFi.h>
#include <PubSubClient.h>

#define BMP_SCK 13
#define BMP_MISO 12
#define BMP_MOSI 11
#define BMP_CS 10

/* Verwenden Sie nur die folgende Zeile, wenn I2C-Verdrahtung*/
Adafruit_BMP280 bme; // I2C

const char* ssid = "<WLAN-SSID hier>";
const char* pass = "<WLAN-Passwort hier>";

// MQTT-Serverparameter: Server, Port, Benutzer, Passwort und eindeutige Client-ID
const char* mqtt_server = "<Hostname oder IP des MQTT-Brokers hier>";
const int   mqtt_port = 1883;
const char* mqtt_user = "bmp280";
const char* mqtt_pass = "bmp280";
const char *mqtt_topic = "sensordaten";
String mqtt_clientid = "";

WiFiClient espClient;
PubSubClient client(mqtt_server, mqtt_port, espClient);

/**************************
*   S E T U P
    **************************/
    void setup() {

Serial.begin(9600);

//set the input pins for SDA and SCL (I2C)
Wire.begin(D1,D2);
if (!bme.begin()) {  
Serial.println("Could not find a valid BMP280 sensor, check wiring!");
end();
}
setup_wifi();

mqtt_clientid = String(ESP.getChipId());
}

// Mit WLAN-Netzwerk verbinden
void setup_wifi() {
delay(10);

//Überprüfen der Anwesenheit des WLAN-Shields
if(WiFi.status() == WL_NO_SHIELD){
Serial.println("WLAN-Shield nicht vorhanden");
end();
}

while(WiFi.status() != WL_CONNECTED ){
Serial.print("Versuch, eine Verbindung mit SSID herzustellen: ");
Serial.println(ssid);
//Verbindung über WPA/WPA2 herstellen
WiFi.begin(ssid,pass);
//10 Sekunden warten, dann erneut versuchen
delay(10000);
}

Serial.println();
Serial.println("WLAN verbunden");  
Serial.print("IP-Adresse: ");
Serial.print(WiFi.localIP());
Serial.print(" Signalstärke (RSSI):");
Serial.print(WiFi.RSSI());
Serial.println(" dBm");
}
void end(){
while(1);
}

/**************************
*  L O O P
   **************************/
   void loop() {

if (!client.connected()) {
reconnect();
}
client.loop();

String payload = "{";

payload += "\"temp\":";
payload += bme.readTemperature();
payload += ",\"tempUnit\":\"C\"";

payload += ",\"pres\":";
payload += bme.readPressure();
payload += ",\"presUnit\":\"Pa\"";

payload += ",\"alt\":";
payload += bme.readAltitude(1013.25);
payload += ",\"altUnit\":\"m\"";
payload += ",\"altRefPres\":";
payload += 1013.25;

payload += "}";

Serial.println(payload);
if (client.publish(mqtt_topic, (char*) payload.c_str())) {
Serial.println("Veröffentlichung ok");
} else {
Serial.println("Veröffentlichung fehlgeschlagen");
}

// 5 Sekunden warten
delay(5000);
}

// Verbindung mit MQTT-Broker herstellen
void reconnect() {
while (!client.connected()) {
Serial.print("MQTT-Verbindung wird versucht...");
Serial.println(mqtt_clientid);

    if (client.connect(mqtt_clientid.c_str(), mqtt_user, mqtt_pass)) {
      Serial.println("MQTT verbunden");
    } 
    else {
      Serial.print("fehlgeschlagen, rc=");
      Serial.print(client.state());
      Serial.println(" erneuter Versuch in 5 Sekunden");
      // 5 Sekunden warten, bevor erneut versucht wird
      delay(5000);
    }
}
delay(500);
}

<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-mqtt-server</artifactId>
<version>3.4.2</version>
</dependency>

/**********************************************
* DevCon5 GmbH, info@devcon5.ch
* Vertx MQTT-Broker
  **********************************************/
  package ch.devcon5.mqtt;

import io.netty.handler.codec.mqtt.MqttQoS;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future;
import io.vertx.core.Vertx;
import io.vertx.core.json.JsonObject;
import io.vertx.mqtt.MqttServer;

public class VertxMQTTServer extends AbstractVerticle {

    public static void main(String... args) {

        final Vertx vertx = Vertx.vertx();
        vertx.deployVerticle(new VertxMQTTServer());
    }

    @Override
    public void start(final Future<Void> startFuture) throws Exception {

        final MqttServer mqttServer = MqttServer.create(vertx);
        mqttServer.endpointHandler(endpoint -> {
            System.out.printf("MQTT-Client [%s] Anfrage zur Verbindung, saubere Sitzung = %s %n",
                              endpoint.clientIdentifier(),
                              endpoint.isCleanSession());

            endpoint.publishHandler(message -> {
                final JsonObject msg = message.payload().toJsonObject();

                System.out.printf("Empfangene Nachricht [%s] mit QoS [%s]%n", msg, message.qosLevel());

                //TODO auf die Nachricht reagieren

                if (message.qosLevel() == MqttQoS.AT_LEAST_ONCE) {
                    endpoint.publishAcknowledge(message.messageId());
                } else if (message.qosLevel() == MqttQoS.EXACTLY_ONCE) {
                    endpoint.publishRelease(message.messageId());
                }
            }).publishReleaseHandler(endpoint::publishComplete);
            endpoint.accept(false);

        }).listen(ar -> {
            if (ar.succeeded()) {
                System.out.println("MQTT-Server hört auf Port " + ar.result().actualPort());
                startFuture.complete();
            } else {
                System.out.println("Fehler beim Starten des Servers");
                startFuture.fail(ar.cause());
            }
        });
    }
}