Mi programa se divide en un server alojado en una raspberry y programado en Python y un cliente hecho en Qt con C++ (Abajo adjunto código). He conseguido comunicarlos de forma correcta excepto por una cosa. La idea es muy sencilla, quiero que el cliente envíe algo "Hola mundo"
y el server conteste con un "True"
, pudiendo hacer esto todas las veces necesarias sin que varíe el resultado (Hola mundo - True
).
El problema viene a la hora de ejecutar esa acción varias veces, es decir, cuando yo pulso el botón de ejecutar que he programado la primera acción se realiza a la perfección, mi server recibe un "Hola mundo"
y el cliente un "True"
. PERO cuando ejecuto más de una vez empieza la guerra, se me solapan los datos, es decir, el server recibe "Hola MundoHola Mundo"
y el cliente "True"
""
y así sucesivamente.
Ando bastante perdido, creí que podía ser el bucle while de python o que una vez terminaba la primera acción era conveniente cerrar el socket y volver a abrirlo, es decir, usar un socket nuevo para cada acción, pero no he conseguido nada que funcione. Consejos?
Codigo Server:
import socket
s =socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.bind(("IP",puerto))
s.listen(10)
def repro():
mensaje = sc.recv(30)
message = 'True'.encode('UTF-8')
sc.send(message)
print ('Mensaje:',mensaje)
sc.close()
while True:
(sc,addr) = s.accept()
while True:
repro()
break
sc.close()
Codigo Cliente en Qt:
#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <QDebug>
#include <QHostAddress>
#include <windows.h>
MainWindow::MainWindow(QWidget *parent) :
QMainWindow(parent),
ui(new Ui::MainWindow),
_socket(this)
{
ui->setupUi(this);
}
MainWindow::~MainWindow()
{
delete ui;
}
void MainWindow::lectura()
{
//Funcion receptora del mensaje del server:
QByteArray datas = _socket.readAll();
qDebug() << datas;
}
void MainWindow::onReadyRead()
{
//Funcion encargada de mandar mensaje al server:
char check[10] = "32";
_socket.write("Hola mundo");
}
void MainWindow::on_pushButton_clicked()
{
//Al apretar el boton nos conectamos al Host y realizamos las funciones de lectura y escritura:
_socket.connectToHost(QHostAddress("IP"), puerto);
connect(&_socket, SIGNAL(connected()), this, SLOT(onReadyRead()));
connect(&_socket, SIGNAL(readyRead()), this, SLOT(lectura()));
}