I can connect, and send data from esp8266 to broker(MQTT-server). But in many example on Internet I have tried, all of this is use available server (like ws://broker.hivemq.com:8000/mqtt ), I need make a broker by myself and i wanna send data from broker to ESP8266.Sorry, my english is bad, thanks you so much

ESP8266

const char* ssid = "redmi";        

const char* password = "123456789";

const char* mqtt_server = "192.168.43.206";

WiFiClient espClient;

PubSubClient client(espClient);

long lastMsg = 0;

char msg[50];

int value = 0;

bool comefromserver;







void setup_wifi() {



  delay(10);

  // We start by connecting to a WiFi network

  Serial.println();

  Serial.print("Connecting to ");

  Serial.println(ssid);



  WiFi.begin(ssid, password);



  while (WiFi.status() != WL_CONNECTED) {

    delay(500);

    Serial.print(".");

  }



  randomSeed(micros());



  Serial.println("");

  Serial.println("WiFi connected");

  Serial.println("IP address: ");

  Serial.println(WiFi.localIP());

}



void callback(char* topic, byte* payload, unsigned int length) {

  Serial.print("Message arrived [");

  Serial.print(topic);

  Serial.print("] ");

  for (int i = 0; i < length; i++) {

    Serial.print((char)payload[i]);

  }

  Serial.println();



  // Switch on the LED if an 1 was received as first character

  if ((char)payload[0] == '1') {

    digitalWrite(BUILTIN_LED, LOW);   // Turn the LED on (Note that LOW is the voltage level

    // but actually the LED is on; this is because

    // it is active low on the ESP-01)

  } else {

    digitalWrite(BUILTIN_LED, HIGH);  // Turn the LED off by making the voltage HIGH

  }



}



void reconnect() {

  // Loop until we're reconnected

  while (!client.connected()) {

    Serial.print("Attempting MQTT connection...");

    // Create a random client ID

    String clientId = "ESP8266Client-";

    clientId += String(random(0xffff), HEX);

    // Attempt to connect

    if (client.connect(clientId.c_str(),"","")) {

      Serial.println("connected");



      // Once connected, publish an announcement...

      client.publish("clientConnected", "clientConnected");

      // ... and resubscribe

      Serial.println(msg);      

    } else {

      Serial.print("failed, rc=");

      Serial.print(client.state());

      Serial.println(" try again in 5 seconds");

      // Wait 5 seconds before retrying 

      delay(5000);

    }

  }

}

void setup() {

  pinMode(BUILTIN_LED, OUTPUT);     // Initialize the BUILTIN_LED pin as an output

  Serial.begin(115200);

  setup_wifi();

  client.setServer(mqtt_server, 1883);

  client.setCallback(callback);

}

void loop() {

    if (!client.connected()) {

    reconnect();

  }

  client.loop();



  long now = millis();

  if (now - lastMsg > 2000) {

    lastMsg = now;

    ++value;

    snprintf (msg, 50, "hello world #%ld", value);

    Serial.print("Publish message: ");

    Serial.println(msg);

    client.publish("outTopic", msg);

}

Server

var mosca = require('mosca');

var settings = {

  port: 1883,

};

var server = new mosca.Server(settings);

server.on('clientConnected', function(client) {

    console.log('client connected', client);

});

server.on('published', function(packet, client) {

  console.log('Published', packet.payload.toString('utf8'));

});

server.on('ready', setup);



function setup() {

  console.log('Mosca server is up and running');

}