Здравствуйте. У меня есть TCP-сервер на одной машине и TCP-клиент на другой машине.
Клиент подключается к серверу и передает ему пакеты данных.
Количество пакетов 40000+.
Длина пакетов до 400 байт.
При выдаче пакетов с периодом 50 мс есть потери пакетов на сервере.
При выдаче пакетов с периодом 200 мс потерь пакетов на сервере очень редкие.
Программа написана на Qt4.
Вопросы:1. Нужна скорость передачи и приема 150 kbit/s без потерь пакетов.
Что доделать в программе?
2. Нужно ли для этого увеличивать частоту выдачи или надо увеличивать объем
передаваемых данных?
3. Надо ли использовать QDataStream для передачи данных?
4. Как возможно увеличить скорость передачи-приема до 1 Mbit/s.
5. Как измерить скорость передачи-приема в Kbit/s?
Текст сервера:#define READ_BUF_SIZE 10000
char buf_c[8000000];
//конструктор
{
//TCP-сервер
clientConnection = new QTcpSocket(this);
tcpServer = new QTcpServer();
connect(tcpServer, SIGNAL(newConnection()), this, SLOT(newConnect()));
connect(wdgComm, SIGNAL(tcp_init()), SLOT(tcp_init()));
}
void frmMain::tcp_init()
{
if (tcpServer->isListening())
{
tcpServer->close();
}
if (!tcpServer->listen(QHostAddress::Any, wdgComm->spbHostPort->value()))
{
//TCP-серверу не удалось запуститься
return;
}
}
void frmMain::newConnect()
{
clientConnection = tcpServer->nextPendingConnection();
connect(clientConnection, SIGNAL(readyRead()),
this, SLOT(receivePkg()));
connect(clientConnection, SIGNAL(disconnected()),
clientConnection, SLOT(deleteLater()));
}
void frmMain::receivePkg()
{
if(listSt.at(0).toInt()==21)
s_t();
}
void frmMain::s_t()
{
read_size = clientConnection->read(buf_c, READ_BUF_SIZE);
}
Текст клиента://класс главного окна
//конструктор
{
t = new QTimer(this);
t->setSingleShot(false);
t->setInterval(50); // период выдачи, мс
connect(t, SIGNAL(timeout()), SLOT(write2()));
//net
wdgComm = new frmComm(this);
connect(pushButton_2, SIGNAL(clicked()), wdgComm, SLOT(show()));//
port = wdgComm->port();
}
int frmMain::write2()
{
QByteArray pkg;
for(j=0; j<mas_t_size[kol_send]; j++)
{
pkg[j]=mas_t[kol_send][j];
}
port->write(pkg);
}
//класс окна настройки адреса и порта
class frmComm : public QWidget, public Ui::wdgComm
{
Q_OBJECT
public :
frmComm(QWidget * parent = 0);
commDevice * port(void) { return com_port; }
public slots :
void reset(void);
private :
QSettings * settings;
commDevice * com_port;
};
//конструктор окна настройки
frmComm::frmComm(QWidget * parent) : QWidget(parent, Qt::Window)
{
connect(btnSet, SIGNAL(clicked()), SLOT(reset()));
settings = new QSettings("comm.ini", QSettings::IniFormat, this);
ledHostAddress->setText(settings->value("host_address", "192.168.0.100").toString());
spbHostPort->setValue(settings->value("host_port", 5200).toInt());
com_port = new commDevice(this);
return;
}
void frmComm::reset(void)
{
settings->setValue("host_address", ledHostAddress->text());
settings->setValue("host_port", spbHostPort->value());
com_port->close();
com_port->connectToHost(ledHostAddress->text(), spbHostPort->value());
return;
}
//класс клиента
commDevice::commDevice(QObject * parent) : QObject(parent)
{
comm_state = commDevice::Disconnect;
close_flag = FALSE;
socket = new QTcpSocket(this);
connect(socket, SIGNAL(error(QAbstractSocket::SocketError)), SLOT(socketError(QAbstractSocket::SocketError)));
connect(socket, SIGNAL(disconnected()), SLOT(socketDisconnected()));
connect(socket, SIGNAL(readyRead()), SLOT(readDevice()));
socket_reconnect_timer = new QTimer(this);
socket_reconnect_timer->setSingleShot(TRUE);
socket_reconnect_timer->setInterval(10000); // период переподключения сокета, мс
return;
}
void commDevice::connectToHost(const QString & hostName, quint16 port)
{
close_flag = FALSE;
host_name = hostName;
host_port = port;
reconnectToHost();
return;
}
void commDevice::reconnectToHost(void)
{
socket->connectToHost(host_name, host_port);
if(socket->waitForConnected(10000))
{
comm_state = commDevice::TCPSocket;
//(tr("Выполнено подключение к TCP-серверу\n", ""), Qt::black);
}
return;
}
void commDevice::socketDisconnected(void)
{
comm_state = commDevice::Disconnect;
if(!close_flag)
socket_reconnect_timer->start();
return;
}
void commDevice::socketError(QAbstractSocket::SocketError err)
{
switch(err)
{
case QAbstractSocket::ConnectionRefusedError :
//(tr("Соединение не выполнено", "The connection was refused by the peer (or timed out)."), Qt::red);
break;
case QAbstractSocket::RemoteHostClosedError :
//(tr("Удаленный сервер закрыл соединение", "The remote host closed the connection."), Qt::red);
break;
case QAbstractSocket::HostNotFoundError :
//(tr("Удаленный сервер не найден", "The host address was not found."), Qt::red);
break;
default :
//(tr("Ошибка сокета ") + QString::number(err), Qt::red);
}
socket->abort();
comm_state = commDevice::Disconnect;
socket_reconnect_timer->start();
return;
}
//функция выдачи пакета
int commDevice::write(const QByteArray & pkg)
{
DWORD charsWritten = 0;
int written = 0;
bool ok;
written = socket->write(pkg, pkg.size());
return written;
}
Навигация сайта
