1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
/****************************************************************************
**
** Copyright (C) 1992-2008 Trolltech ASA. All rights reserved.
**
** This file is part of an example program for TQt. This example
** program may be used, distributed and modified without limitation.
**
*****************************************************************************/
#include <ntqsocket.h>
#include <ntqserversocket.h>
#include <ntqapplication.h>
#include <ntqvbox.h>
#include <ntqtextview.h>
#include <ntqlabel.h>
#include <ntqpushbutton.h>
#include <ntqtextstream.h>
#include <stdlib.h>
/*
The ClientSocket class provides a socket that is connected with a client.
For every client that connects to the server, the server creates a new
instance of this class.
*/
class ClientSocket : public TQSocket
{
TQ_OBJECT
public:
ClientSocket( int sock, TQObject *parent=0, const char *name=0 ) :
TQSocket( parent, name )
{
line = 0;
connect( this, SIGNAL(readyRead()),
SLOT(readClient()) );
connect( this, SIGNAL(connectionClosed()),
SLOT(deleteLater()) );
setSocket( sock );
}
~ClientSocket()
{
}
signals:
void logText( const TQString& );
private slots:
void readClient()
{
TQTextStream ts( this );
while ( canReadLine() ) {
TQString str = ts.readLine();
emit logText( tr("Read: '%1'\n").arg(str) );
ts << line << ": " << str << endl;
emit logText( tr("Wrote: '%1: %2'\n").arg(line).arg(str) );
line++;
}
}
private:
int line;
};
/*
The SimpleServer class handles new connections to the server. For every
client that connects, it creates a new ClientSocket -- that instance is now
responsible for the communication with that client.
*/
class SimpleServer : public TQServerSocket
{
TQ_OBJECT
public:
SimpleServer( TQObject* parent=0 ) :
TQServerSocket( 4242, 1, parent )
{
if ( !ok() ) {
tqWarning("Failed to bind to port 4242");
exit(1);
}
}
~SimpleServer()
{
}
void newConnection( int socket )
{
ClientSocket *s = new ClientSocket( socket, this );
emit newConnect( s );
}
signals:
void newConnect( ClientSocket* );
};
/*
The ServerInfo class provides a small GUI for the server. It also creates the
SimpleServer and as a result the server.
*/
class ServerInfo : public TQVBox
{
TQ_OBJECT
public:
ServerInfo()
{
SimpleServer *server = new SimpleServer( this );
TQString itext = tr(
"This is a small server example.\n"
"Connect with the client now."
);
TQLabel *lb = new TQLabel( itext, this );
lb->setAlignment( AlignHCenter );
infoText = new TQTextView( this );
TQPushButton *quit = new TQPushButton( tr("Quit") , this );
connect( server, SIGNAL(newConnect(ClientSocket*)),
SLOT(newConnect(ClientSocket*)) );
connect( quit, SIGNAL(clicked()), tqApp,
SLOT(quit()) );
}
~ServerInfo()
{
}
private slots:
void newConnect( ClientSocket *s )
{
infoText->append( tr("New connection\n") );
connect( s, SIGNAL(logText(const TQString&)),
infoText, SLOT(append(const TQString&)) );
connect( s, SIGNAL(connectionClosed()),
SLOT(connectionClosed()) );
}
void connectionClosed()
{
infoText->append( tr("Client closed connection\n") );
}
private:
TQTextView *infoText;
};
int main( int argc, char** argv )
{
TQApplication app( argc, argv );
ServerInfo info;
app.setMainWidget( &info );
info.show();
return app.exec();
}
#include "server.moc"
|
