Сообщения от Flask SocketIO не получены - PullRequest
0 голосов
/ 25 сентября 2019

Я новичок в Flask и IO.Я пытаюсь реализовать базовый приемник данных для машины с RoS.У меня есть скрипт Python, отправляющий данные на веб-сервер, работающий на Flask.Проблема заключается в том, что обратный вызов java-скрипта никогда не вызывается и, следовательно, числа странным образом никогда не добавляются в список, даже если ошибок нет.Соответствующие части таковы:

Внутри веб-сервера Python:

@socketio.on('connect', namespace='/test')
def test_connect():
    print("CALLED")

@socketio.on('disconnect', namespace='/test')
def test_disconnect():
    print('Client disconnected')

Предполагается, что случайное число должно быть определено следующей функцией обратного вызова Ros (она вызывается каждые 0,5 с):

def forklift_callback(self, msg):
    #SOCKET TEST

    number = random.randint(1,101)
    print(number)
    socketio.emit('newnumber', {'number': number}, namespace='/test')

Возможно, важно то, как я это определяю:

*import statements*
from std_msgs.msg import String, UInt32
from umd_msgs.msg import PCNotification, RoverStatus, Barcode


mod = Blueprint('api', __name__)
msg = String()
started = "robot started"

socketio = SocketIO(app)
... All functionality ...

if __name__ == '__main__':
    socketio.run(app)

Это связано с html-страницей в следующем месте:

<html>
<head>
    <script src="//code.jquery.com/jquery-3.3.1.min.js"></script>
    <script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/socket.io/1.3.6/socket.io.min.js"></script>
<script>
        $(document).ready(function(){
            //connect to the socket server.
        console.log('http://' + document.domain + ':' + location.port + '/test')
            var socket = io.connect('http://' + document.domain + ':' + location.port + '/test');
            var numbers_received = [];

            //receive details from server
            socket.on('newnumber', function(msg) {
            console.log("Blank")
                console.log("Received number" + msg.number);
                //maintain a list of ten numbers
                if (numbers_received.length >= 10){
                    numbers_received.shift()
                }
                numbers_received.push(msg.number);
                numbers_string = '';
                for (var i = 0; i < numbers_received.length; i++){
                    numbers_string = numbers_string + '<p>' + numbers_received[i].toString() + '</p>';
                }
                $('#log').html(numbers_string);
            });

        });
</script>
    <link rel="stylesheet" href="//maxcdn.bootstrapcdn.com/bootstrap/3.3.7/css/bootstrap.min.css">
</head>
<body>
<div class="container">
  <div class="jumbotron">
    <h1>Asynchronous Flask Communication</h1>
    <p>Random numbers generated by the Flask server will appear below, asynchronously.</p>

  </div>
</div>

</div>

<div class="container" id="content">
    <div class="row">
        <p>Asynchronous page updates will appear here:</p>
        <h3>Number list:</h3>
        <div id="log">
        </div> <!-- /#log -->
    </div>
</div>

1 Ответ

0 голосов
/ 25 сентября 2019

Попробуйте что-нибудь подобное, возможно, это поможет

Вы можете сделать это с помощью Thread, который будет выполнять вашу функцию

yourThread = Thread()
thread_stop_event = Event()

class someClass(Thread):
  def __init__(self):
    self.delay = 1
    super(someClass,self).__init__()

  def forklift_callback(self):
    while not thread_stop_event.isSet():           
      number = random.randint(1,101)
      print(number)
      socketio.emit('newnumber', {'number': number}, namespace='/test')
      sleep(self.delay)

  def run(self):
    self.forklift_callback()

@socketio.on('connect', namespace='/test')
def test_connect():
  print("CALLED")

  global yourThread
  if(not yourThread.isAlive()):
    yourThread = someClass()
    yourThread.start()

или просто запустить его после того, как клиент подключит ваш сервер

@socketio.on('connect', namespace='/test')
def test_connect():
  //your function here
  print("CALLED")
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...