text: import paho.mqtt.client as mqtt
  
  # The callback for when the client receives a CONNACK response from the server.
  def on_connect(client, userdata, flags, rc):
      print("Connected with result code "+str(rc))
  
      # Subscribing in on_connect() means that if we lose the connection and
      # reconnect then subscriptions will be renewed.
      
      client.publish("vv/join", "hihi", 0, False);
      print("publish success")
  
  # The callback for when a PUBLISH message is received from the server.
  def on_message(client, userdata, msg):
      print(msg.topic+" "+str(msg.payload))
  
  client = mqtt.Client(client_id="hihi")
  client.on_connect = on_connect
  client.on_message = on_message
  
  client.connect("192.168.1.146")
  # Blocking call that processes network traffic, dispatches callbacks and
  # handles reconnecting.
  # Other loop*() functions are available that give a threaded interface and a
  # manual interface.
  client.loop_forever()
  