server1.py

import tornado.httpserver, tornado.websocket, tornado.ioloop, tornado.web
from tornado.options import define, options
import paho.mqtt.client as mqtt
import datetime

#from sense_hat import SenseHat
#sense=SenseHat()
from signal import signal, SIGPIPE, SIG_DFL
signal(SIGPIPE, SIG_DFL)
#global data2
data2=''
#mqttc=mqtt.Client(transport='websockets')
clients = []
client=mqtt.Client()
client.connect("192.168.8.100",1883,60)
client.subscribe("robotmonitoring")
client.loop_start()

class WSHandler(tornado.web.RequestHandler):
  def get(self):
    self.write("This is your response")
    print 'get message'
    self.finish()

class WebSocketHandler(tornado.websocket.WebSocketHandler):
  def check_origin(self, origin):
  	return True
  def open(self, *args):
  	#global data2
  	print 'user is connected.\n'
  	self.connected=True
  	self.timeout_loop()
  	#self.on_message(client, userdata, msg)
  def on_message(self, message):
  	global data2
  	message=data2
  	print 'received message: %s\n' %message
    #self.write_message(message + ' OK')
    #data2.show_message(message)
  def on_close(self):
    print 'connection closed\n'
    self.connected=False
  def timeout_loop(self):
    global data2
    if self.connected:
     #t=sense.get_temperature()
	 #t=round(t,2)
	 #print t
	  t=data2
	  #print data2
	  self.write_message('%s' %t)
	  tornado.ioloop.IOLoop.instance().add_timeout(datetime.timedelta(seconds=1),self.timeout_loop)
  def on_connect(client, userdata, flags, rc):
    print("Connected with result code" + str(rc))
  def on_message(client, userdata, msg):
    global data2
    data2=msg.payload
    print data2
  #return data
#data3=data
  client.on_connect=on_connect
  client.on_message=on_message
if __name__ == "__main__":
  app = tornado.web.Application(handlers=[(r'/', WebSocketHandler),])
  server=tornado.httpserver.HTTPServer(app)
  server.bind(8888)
  server.start(0)
  #app.listen(8888)
  print "Server Start"
  tornado.ioloop.IOLoop.instance().start()