答案修订版
此代码包括 3 个脚本:
serverJ.pl
这是一个迭代服务器,一次处理一个请求,但继续处理多个请求;
clientJ.pl
这是一个简单的客户端,它从文件发送登录请求Login.txt
并回显它从服务器接收到的内容;和
clientQ.pl
它向服务器发送 QUIT 消息。
我保留了使用老式文件句柄的代码,而不是升级到现代词汇文件句柄,但我更改为open
. 另一个变化是大多数消息都以$$:
Perl 进程 ID 为前缀。INNER:
除了与循环对称之外,我不会标记OUTER:
循环,这确实需要一个标签。目前尚不清楚中需要的功能send_login()
和; 他们尊重原始代码。abc()
clientJ.pl
服务器J.pl
#!/usr/bin/env perl
use strict;
use warnings;
use IO::Socket::INET;
my $socket = new IO::Socket::INET (
LocalHost => '127.0.0.1',
LocalPort => '1055',
Proto => 'tcp',
Listen => 1,
Reuse => 1
) or die "Oops: $! \n";
print "$$: waiting for clients.\n";
server_loop();
$socket->close();
sub server_loop
{
OUTER:
while (my $clientsocket = $socket->accept())
{
print "$$: connected from : ", $clientsocket->peerhost();
print ", port : ", $clientsocket->peerport(), "\n";
INNER:
while (<$clientsocket>)
{
print"$$: Message received from Client : $_";
last INNER if ($_ eq "\$END\$\n");
last OUTER if ($_ eq "\$QUIT\$\n");
print $clientsocket $_;
}
my $login_ack = "login_ack.txt";
open LOGINACK, '<', $login_ack or die "Cannot open login acknowledgment file $login_ack ($!)\n";
my @loginack = <LOGINACK>;
close LOGINACK;
my $logfile = "logfile.txt";
open LOG, ">>", $logfile or die "$$: cannot open $logfile ($!)\n";
foreach my $loginack (@loginack)
{
last if ($loginack eq "\$END\$\n");
print $clientsocket $loginack;
print LOG "$$: $loginack";
print "$$: server to client: $loginack";
}
close LOG;
close $clientsocket;
}
}
客户J.pl
#!/usr/bin/env perl
use strict;
use warnings;
use IO::Socket::INET;
my $socket = new IO::Socket::INET (
PeerHost => '127.0.0.1',
PeerPort => '1055',
Proto => 'tcp',
Reuse => 1
) or die "$!\n";
print "$$: connected to the server.\n";
send_login();
abc();
$socket->close();
sub send_login
{
my $login_txt = "Login.txt";
open LOGIN, '<', $login_txt or die "Cannot open $login_txt $!\n";
my @login = <LOGIN>;
close LOGIN;
my $logfile = "logfile.txt";
open LOG, '>>', $logfile or die "Cannot open $logfile ($!)\n";
foreach my $login (@login)
{
print $socket $login;
print LOG "$$: $login";
print "$$: sent to server: $login";
last if ($login eq "\$END\$\n");
}
close LOG;
}
sub abc
{
while (<$socket>)
{
print"$$: Message received from Server: $_";
}
}
客户端Q.pl
#!/usr/bin/env perl
use strict;
use warnings;
use IO::Socket::INET;
my $socket = new IO::Socket::INET(
PeerHost => '127.0.0.1',
PeerPort => '1055',
Proto => 'tcp',
Reuse => 1
) or die "$!\n";
print $socket "\$QUIT\$\n";
$socket->close();
样本日志
$ perl serverJ.pl 2>&1 &
[1] 87610
$ 87610: waiting for clients.
$ perl clientJ.pl | so
87610: connected from : 127.0.0.1, port : 57143
87610: Message received from Client : SAS4
87610: Message received from Client : 50
87610: Message received from Client : SAS_ACTION LOGIN
87610: Message received from Client : LOGIN bss
87610: Message received from Client : PASSWORD cleint
87610: Message received from Client : $END$
87610: server to client: SAS4
87610: server to client: 61
87610: server to client: SAS_ACTION LOGIN_ACK
87610: server to client: ACK_STATUS 0
87610: server to client: ACK_MESSAGE Logged In
87614: connected to the server.
87614: sent to server: SAS4
87614: sent to server: 50
87614: sent to server: SAS_ACTION LOGIN
87614: sent to server: LOGIN bss
87614: sent to server: PASSWORD cleint
87614: sent to server: $END$
87614: Message received from Server: SAS4
87614: Message received from Server: 50
87614: Message received from Server: SAS_ACTION LOGIN
87614: Message received from Server: LOGIN bss
87614: Message received from Server: PASSWORD cleint
87614: Message received from Server: SAS4
87614: Message received from Server: 61
87614: Message received from Server: SAS_ACTION LOGIN_ACK
87614: Message received from Server: ACK_STATUS 0
87614: Message received from Server: ACK_MESSAGE Logged In
$ perl clientJ.pl | so
87610: connected from : 127.0.0.1, port : 57144
87610: Message received from Client : SAS4
87610: Message received from Client : 50
87610: Message received from Client : SAS_ACTION LOGIN
87610: Message received from Client : LOGIN bss
87610: Message received from Client : PASSWORD cleint
87610: Message received from Client : $END$
87610: server to client: SAS4
87610: server to client: 61
87610: server to client: SAS_ACTION LOGIN_ACK
87610: server to client: ACK_STATUS 0
87610: server to client: ACK_MESSAGE Logged In
87617: connected to the server.
87617: sent to server: SAS4
87617: sent to server: 50
87617: sent to server: SAS_ACTION LOGIN
87617: sent to server: LOGIN bss
87617: sent to server: PASSWORD cleint
87617: sent to server: $END$
87617: Message received from Server: SAS4
87617: Message received from Server: 50
87617: Message received from Server: SAS_ACTION LOGIN
87617: Message received from Server: LOGIN bss
87617: Message received from Server: PASSWORD cleint
87617: Message received from Server: SAS4
87617: Message received from Server: 61
87617: Message received from Server: SAS_ACTION LOGIN_ACK
87617: Message received from Server: ACK_STATUS 0
87617: Message received from Server: ACK_MESSAGE Logged In
$ perl clientQ.pl | so
87610: connected from : 127.0.0.1, port : 57147
87610: Message received from Client : $QUIT$
[1]+ Done perl serverJ.pl 2>&1
$
后循环代码执行
在服务器脚本中,在发送确认时,foreach my $loginack (@loginack)
循环之后的代码不会被执行。我认为这是因为代码无法跳出循环。将如何处理?
轻微修改的代码serverJ.pl
:
foreach my $loginack (@loginack)
{
last if ($loginack eq "\$END\$\n");
print $clientsocket $loginack;
print LOG "$$: $loginack";
print "$$: server to client: $loginack";
}
print "$$: End of Loop\n";
close LOG;
close $clientsocket;
print "$$: After close\n";
示例运行:
$ perl serverJ.pl &
[1] 6913
$ 6913: waiting for clients.
$ perl clientJ.pl
6915: connected to the server.
6913: connected from : 127.0.0.1, port : 52454
6915: sent to server: This is the file Login.txt
6913: Message received from Client : This is the file Login.txt
6915: sent to server: It contains more than 1 line
6915: sent to server: It also contains this one
6915: sent to server: $END$
6913: Message received from Client : It contains more than 1 line
6913: Message received from Client : It also contains this one
6913: Message received from Client : $END$
6915: Message received from Server: This is the file Login.txt
6915: Message received from Server: It contains more than 1 line
6915: Message received from Server: It also contains this one
6913: server to client: This is the file login_ack.txt
6913: server to client: As with the other file, it contains multiple lines
6913: server to client: Several of them.
6913: server to client: This is one of them.
6915: Message received from Server: This is the file login_ack.txt
6913: End of Loop
6915: Message received from Server: As with the other file, it contains multiple lines
6915: Message received from Server: Several of them.
6915: Message received from Server: This is one of them.
6913: After close
$ perl clientQ.pl
6913: connected from : 127.0.0.1, port : 52455
6913: Message received from Client : $QUIT$
[1]+ Done perl serverJ.pl
$
答案原版
这段代码似乎对我有用(对于“作品”的松散定义)。它与您的代码密切相关,但使用套接字 1055 而不是 0155(我在 Unix 上运行;我必须是 root 才能使用小于 1024 的端口号),并使用use strict;
和use warnings;
其他小的清理。
服务器.pl
#!/usr/bin/env perl
use strict;
use warnings;
use IO::Socket::INET;
my $socket = new IO::Socket::INET( LocalHost => '127.0.0.1', LocalPort => '1055', Proto => 'tcp', Listen => 1, Reuse => 1 ) or die "Oops: $! \n";
print "Waiting for the Client.\n";
my $clientsocket;
while ($clientsocket = $socket->accept())
{
print "Connected from : ", $clientsocket->peerhost();
print ", Port : ", $clientsocket->peerport(), "\n";
while (<$clientsocket>)
{
if ($_ ne "\$END\$\n")
{
print"Message received from Client : $_";
print $clientsocket $_;
}
else
{
print"\$END\$\n";
}
}
last;
}
login_ack();
sub login_ack
{
# Some code removed for the purpose of posting
open (LOGINACK, "login_ack.txt") || die "Cannot open login acknowledgment file $!\n";
my @loginack=<LOGINACK>;
close LOGINACK;
open(LOG, ">>logfile.txt");
foreach my $loginack (@loginack)
{
if ($loginack ne "\$END\$\n")
{
print $clientsocket $loginack;
print LOG $loginack;
print $loginack;
}
else
{
print"\$END\$\n";
}
}
}
客户端.pl
#!/usr/bin/env perl
use strict;
use warnings;
use IO::Socket::INET;
my $socket = new IO::Socket::INET ( PeerHost => '127.0.0.1', PeerPort => '1055', Proto => 'tcp', Reuse => 1) or die "$!\n";
print "Connected to the Server.\n";
send_login();
sub send_login
{
# Some code removed for the purpose of posting
open (LOGIN, "Login.txt") || die "Cannot open login file $!\n";
my @login=<LOGIN>;
close LOGIN;
open(LOG, ">>logfile.txt");
foreach my $login (@login)
{
if ($login ne "\$END\$\n")
{
print $socket $login;
print LOG $login;
print $login;
}
else
{
print"\$END\$\n";
}
}
}
LOGINACK:
while (<$socket>)
{
print"Message received from Server : $_";
print $socket $_;
last LOGINACK;
}
登录.txt
This is the content of the Login.txt file.
$END$
login_ack.txt
This is the contents of the login_ack.txt file.
It has two lines of text plus the $END$ line.
$END$
样本输出
$ perl server.pl &
[1] 74838
$ Waiting for the Client.
$ perl client.pl | so
Connected from : 127.0.0.1, Port : 51109
Message received from Client : This is the content of the Login.txt file.
Message received from Client : This is the content of the Login.txt file.
Connected to the Server.
This is the content of the Login.txt file.
$END$
Message received from Server : This is the content of the Login.txt file.
This is the contents of the login_ack.txt file.
It has two lines of text plus the $END$ line.
$END$
[1]+ Done perl server.pl
$
服务器在响应单个请求后终止。