开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 外挂编程 > 查看源码
DirectConnection.pm
资源名称：openkore-2.0.7.zip　[点击查看]
上传用户：market2
上传日期：2018-11-18
资源大小：18786k
文件大小：18k
源码类别：

外挂编程

开发平台：

Windows_Unix

DirectConnection.pm：源码内容
  1. #########################################################################
  2. #  OpenKore - Networking subsystem
  3. #  This module contains functions for sending packets to the server.
  4. #
  5. #  This software is open source, licensed under the GNU General Public
  6. #  License, version 2.
  7. #  Basically, this means that you're allowed to modify and distribute
  8. #  this software. However, if you distribute modified versions, you MUST
  9. #  also distribute the source code.
  10. #  See http://www.gnu.org/licenses/gpl.html for the full license.
  11. #
  12. #  $Revision: 5249 $
  13. #  $Id: Network.pm 5249 2006-12-25 14:40:58Z vcl_kore $
  14. #
  15. #########################################################################
  16. ##
  17. # MODULE DESCRIPTION: Connection handling
  18. #
  19. # The Network module handles connections to the Ragnarok Online server.
  20. # This module only handles connection issues, and nothing else. It doesn't do
  21. # anything with the actual data. Network data handling is performed by
  22. # the @MODULE(Network::Receive) and Network::Receive::ServerTypeX classes.
  23. #
  24. # The submodule @MODULE(Network::Send) contains functions for sending all
  25. # kinds of messages to the RO server.
  26. #
  27. # Please also read <a href="http://www.openkore.com/wiki/index.php/Network_subsystem">the
  28. # network subsystem overview.</a>
  29. #
  30. # This implementation establishes a direct connection to the RO server.
  31. # Note that there are alternative implementations for this interface: @MODULE(Network::XKore),
  32. # @MODULE(Network::XKore2) and @MODULE(Network::XKoreProxy)
  34. package Network::DirectConnection;
  36. use strict;
  37. use Modules 'register';
  38. use Exporter;
  39. use base qw(Exporter);
  40. use Time::HiRes qw(time);
  41. use IO::Socket::INET;
  42. use encoding 'utf8';
  43. use Scalar::Util;
  44. use File::Spec;
  46. use Globals;
  47. use Log qw(message error);
  48. use Network;
  49. use Network::Send ();
  50. use Plugins;
  51. use Settings;
  52. use Interface;
  53. use Utils qw(dataWaiting timeOut);
  54. use Utils::Exceptions;
  55. use Misc qw(chatLog);
  56. use Translation;
  58. ##
  59. # Network::DirectConnection->new([wrapper])
  60. # wrapper: If this object is to be wrapped by another object which is interface-compatible
  61. #          with the Network::DirectConnection class, then specify the wrapper object here. The message
  62. #          sender will use this wrapper to send socket data. Internally, the reference to the wrapper
  63. #          will be stored as a weak reference.
  64. #
  65. # Create a new Network::DirectConnection object. The connection is not yet established.
  66. sub new {
  67. my ($class, $wrapper) = @_;
  68. my %self;
  70. $self{remote_socket} = new IO::Socket::INET;
  71. if ($wrapper) {
  72. $self{wrapper} = $wrapper;
  73. Scalar::Util::weaken($self{wrapper});
  74. }
  76. return bless %self, $class;
  77. }
  79. ##
  80. # int $net->version()
  81. #
  82. # Returns the implementation number this object.
  83. sub version {
  84. return 0;
  85. }
  87. sub DESTROY {
  88. my $self = shift;
  90. $self->serverDisconnect();
  91. }
  94. ######################
  95. ## Server Functions ##
  96. ######################
  98. ##
  99. # boolean $net->serverAliveServer()
  100. #
  101. # Check whether the connection to the server is alive.
  102. sub serverAlive {
  103. return $_[0]->{remote_socket} && $_[0]->{remote_socket}->connected();
  104. }
  106. ##
  107. # String $net->serverPeerHost()
  108. #
  109. # If the connection to the server is alive, returns the host name of the server.
  110. # Otherwise, returns undef.
  111. sub serverPeerHost {
  112. return $_[0]->{remote_socket}->peerhost if ($_[0]->serverAlive);
  113. return undef;
  114. }
  116. ##
  117. # int $net->serverPeerPort()
  118. #
  119. # If the connection to the server is alive, returns the port number of the server.
  120. # Otherwise, returns undef.
  121. sub serverPeerPort {
  122. return $_[0]->{remote_socket}->peerport if ($_[0]->serverAlive);
  123. return undef;
  124. }
  126. ##
  127. # $net->serverConnect(String host, int port)
  128. # host: the host name/IP of the RO server to connect to.
  129. # port: the port number of the RO server to connect to.
  130. #
  131. # Establish a connection to a Ragnarok Online server.
  132. #
  133. # This function is used internally by $net->checkConnection() and should not be used directly.
  134. sub serverConnect {
  135. my $self = shift;
  136. my $host = shift;
  137. my $port = shift;
  138. my $return = 0;
  140. Plugins::callHook('Network::connectTo', {
  141. socket => $self->{remote_socket},
  142. return => $return,
  143. host => $host,
  144. port => $port
  145. });
  146. return if ($return);
  148. message TF("Connecting (%s:%s)... ", $host, $port), "connection";
  149. $self->{remote_socket} = new IO::Socket::INET(
  150. LocalAddr => $config{bindIp} || undef,
  151. PeerAddr => $host,
  152. PeerPort => $port,
  153. Proto => 'tcp',
  154. Timeout => 4);
  155. ($self->{remote_socket} && inet_aton($self->{remote_socket}->peerhost()) eq inet_aton($host)) ?
  156. message T("connectedn"), "connection" :
  157. error(TF("couldn't connect: %s (error code %d)n", "$!", int($!)), "connection");
  158. if ($self->getState() != Network::NOT_CONNECTED) {
  159. $incomingMessages->nextMessageMightBeAccountID();
  160. }
  161. }
  163. ##
  164. # void $net->serverSend(Bytes data)
  165. #
  166. # If the connection to the server is alive, send data to the server.
  167. # Otherwise, this method does nothing.
  168. sub serverSend {
  169. my $self = shift;
  170. my $msg = shift;
  171. if ($self->serverAlive) {
  172. if (Plugins::hasHook("Network::serverSend/pre")) {
  173. Plugins::callHook("Network::serverSend/pre", { msg => $msg });
  174. }
  175. if (defined $msg) {
  176. $self->{remote_socket}->send($msg);
  177. if (Plugins::hasHook("Network::serverSend")) {
  178. Plugins::callHook("Network::serverSend", { msg => $msg });
  179. }
  180. }
  181. }
  182. }
  184. ##
  185. # Bytes $net->serverRecv()
  186. #
  187. # Receive data from the RO server.
  188. sub serverRecv {
  189. my $self = shift;
  190. my $msg;
  192. return undef unless (dataWaiting($self->{remote_socket}));
  194. $self->{remote_socket}->recv($msg, 1024 * 32);
  195. if (Plugins::hasHook("Network::serverRecv")) {
  196. Plugins::callHook("Network::serverRecv", { msg => $msg });
  197. }
  198. if (!defined($msg) || length($msg) == 0) {
  199. # Connection from server closed.
  200. close($self->{remote_socket});
  201. return undef;
  202. }
  203. return $msg;
  204. }
  206. ##
  207. # Bytes $net->serverAddress()
  208. #
  209. # Return the server's raw address.
  210. sub serverAddress {
  211. my ($self) = @_;
  212. return $self->{remote_socket}->sockaddr();
  213. }
  215. ##
  216. # $net->serverDisconnect()
  217. #
  218. # Disconnect from the current Ragnarok Online server.
  219. #
  220. # This function is used internally by $net->checkConnection() and should not be used directly.
  221. sub serverDisconnect {
  222. my $self = shift;
  224. if ($self->serverAlive) {
  225. $messageSender->sendQuit() if ($self->getState() == Network::IN_GAME);
  227. message TF("Disconnecting (%s:%s)...", $self->{remote_socket}->peerhost(), 
  228. $self->{remote_socket}->peerport()), "connection";
  229. close($self->{remote_socket});
  230. !$self->serverAlive() ?
  231. message T("disconnectedn"), "connection" :
  232. error T("couldn't disconnectn"), "connection";
  233. }
  234. }
  236. sub getState {
  237. return $conState;
  238. }
  240. sub setState {
  241. my ($self, $state) = @_;
  242. $conState = $state;
  243. Plugins::callHook('Network::stateChanged');
  244. }
  247. ######################
  248. ## Client Functions ##
  249. ######################
  251. ##
  252. # boolean $net->clientAlive()
  253. #
  254. # Check whether there are one or more clients connected to Kore.
  255. sub clientAlive {
  256. my %args = (net => $_[0]);
  257. Plugins::callHook('Network::clientAlive', %args);
  258. return $args{return};
  259. }
  261. ##
  262. # $net->clientSend(Bytes data)
  263. #
  264. # Make the RO client think that it has received $data.
  265. sub clientSend {
  266. my ($self) = @_;
  267. if ($self->clientAlive && Plugins::hasHook('Network::clientSend')) {
  268. my %args = (net => $self, data => $_[1]);
  269. Plugins::callHook('Network::clientSend', %args);
  270. return $args{return};
  271. } else {
  272. return undef;
  273. }
  274. }
  276. ##
  277. # Bytes $net->clientRecv()
  278. #
  279. # Receive data that the RO client wants to send to the RO server.
  280. sub clientRecv {
  281. my ($self) = @_;
  282. if ($self->clientAlive) {
  283. my %args = (net => $_[0]);
  284. Plugins::callHook('Network::clientRecv', %args);
  285. return $args{return};
  286. } else {
  287. return undef;
  288. }
  289. }
  292. #######################
  293. ## Utility Functions ##
  294. #######################
  296. #######################################
  297. #######################################
  298. # Check Connection
  299. #######################################
  300. #######################################
  302. ##
  303. # $net->checkConnection()
  304. #
  305. # Handles any connection issues. Based on the current situation, this function may
  306. # re-connect to the RO server, disconnect, do nothing, etc.
  307. #
  308. # This function is meant to be run in the Kore main loop.
  309. sub checkConnection {
  310. my $self = shift;
  312. return if ($Settings::no_connect);
  314. if ($self->getState() == Network::NOT_CONNECTED && (!$self->{remote_socket} || !$self->{remote_socket}->connected) && timeOut($timeout_ex{'master'}) && !$conState_tries) {
  315. my $master = $masterServer = $masterServers{$config{master}};
  317. foreach my $serverOption ('serverType', 'chatLangCode', 'storageEncryptKey', 'gameGuard', 'charBlockSize',
  318. 'paddedPackets', 'paddedPackets_attackID', 'paddedPackets_skillUseID',
  319. 'mapServer_ip', 'mapServer_port') {
  320. if ($master->{$serverOption} ne '' && $config{$serverOption} ne $master->{$serverOption}) {
  321. main::configModify($serverOption, $master->{$serverOption});
  322. }
  323. }
  324. if ($master->{serverEncoding} ne '' && $config{serverEncoding} ne $master->{serverEncoding}) {
  325. main::configModify('serverEncoding', $master->{serverEncoding});
  326. } elsif ($config{serverEncoding} eq '') {
  327. main::configModify('serverEncoding', 'Western');
  328. }
  329. if (Settings::setRecvPacketsName($masterServer->{recvpackets})) {
  330. my (undef, undef, $basename) = File::Spec->splitpath(Settings::getRecvPacketsFilename());
  331. Settings::loadByRegexp(quotemeta $basename, sub {
  332. my ($filename) = @_;
  333. message TF("Loading %s...n", $filename);
  334. });
  335. }
  337. message T("Connecting to Account Server...n", "connection");
  338. $shopstarted = 1;
  339. $conState_tries++;
  340. $initSync = 1;
  341. $incomingMessages->clear();
  343. eval {
  344. $packetParser = Network::Receive->create($config{serverType});
  345. my $wrapper = ($self->{wrapper}) ? $self->{wrapper} : $self;
  346. $messageSender = Network::Send->create($wrapper, $config{serverType});
  347. };
  348. if ($@) {
  349. $interface->errorDialog("$@");
  350. $quit = 1;
  351. return;
  352. }
  353. $reconnectCount++;
  354. $self->serverConnect($master->{ip}, $master->{port});
  356. # call plugin's hook to determine if we can continue the work
  357. if ($self->serverAlive) {
  358. Plugins::callHook("Network::serverConnect/master");
  359. return if ($conState == 1.5);
  360. }
  362. # GameGuard support
  363. if ($self->serverAlive && $config{gameGuard} == 2) {
  364. my $msg = pack("C*", 0x58, 0x02);
  365. $net->serverSend($msg);
  366. message T("Requesting permission to logon on account server...n");
  367. $conState = 1.2;
  368. return;
  369. }
  371. if ($self->serverAlive && $master->{secureLogin} >= 1) {
  372. my $code;
  374. message T("Secure Login...n"), "connection";
  375. undef $secureLoginKey;
  377. if ($master->{secureLogin_requestCode} ne '') {
  378. $code = $master->{secureLogin_requestCode};
  379. } elsif ($config{secureLogin_requestCode} ne '') {
  380. $code = $config{secureLogin_requestCode};
  381. }
  383. if ($code ne '') {
  384. $messageSender->sendMasterCodeRequest('code', $code);
  385. } else {
  386. $messageSender->sendMasterCodeRequest('type', $master->{secureLogin_type});
  387. }
  389. } elsif ($self->serverAlive) {
  390. $messageSender->sendPreLoginCode($master->{preLoginCode}) if ($master->{preLoginCode});
  391. $messageSender->sendMasterLogin($config{'username'}, $config{'password'},
  392. $master->{master_version}, $master->{version});
  393. }
  395. $timeout{'master'}{'time'} = time;
  397. # we skipped some required connection operations while waiting for the server to allow as to login,
  398. # after we have successfully sent in the reply to the game guard challenge (using the poseidon server)
  399. # this conState will allow us to continue from where we left off.
  400. } elsif ($conState == 1.3) {
  401. $conState = 1;
  402. my $master = $masterServer = $masterServers{$config{'master'}};
  403. if ($master->{secureLogin} >= 1) {
  404. my $code;
  406. message T("Secure Login...n"), "connection";
  407. undef $secureLoginKey;
  409. if ($master->{secureLogin_requestCode} ne '') {
  410. $code = $master->{secureLogin_requestCode};
  411. } elsif ($config{secureLogin_requestCode} ne '') {
  412.   $code = $config{secureLogin_requestCode};
  413. }
  415. if ($code ne '') {
  416. $messageSender->sendMasterCodeRequest('code', $code);
  417. } else {
  418. $messageSender->sendMasterCodeRequest('type', $master->{secureLogin_type});
  419. }
  421. } else {
  422. $messageSender->sendPreLoginCode($master->{preLoginCode}) if ($master->{preLoginCode});
  423. $messageSender->sendMasterLogin($config{'username'}, $config{'password'},
  424. $master->{master_version}, $master->{version});
  425. }
  427. $timeout{'master'}{'time'} = time;
  429. } elsif ($conState == 1 && $masterServer->{secureLogin} >= 1 && $secureLoginKey ne ""
  430.    && !timeOut($timeout{'master'}) && $conState_tries) {
  432. my $master = $masterServer;
  433. message T("Sending encoded password...n"), "connection";
  434. $messageSender->sendMasterSecureLogin($config{'username'}, $config{'password'}, $secureLoginKey,
  435. $master->{version}, $master->{master_version},
  436. $master->{secureLogin}, $master->{secureLogin_account});
  437. undef $secureLoginKey;
  439. } elsif ($conState == 1 && timeOut($timeout{'master'}) && timeOut($timeout_ex{'master'})) {
  440. if ($config{dcOnMaxReconnections} && $config{dcOnMaxReconnections} <= $reconnectCount) {
  441. $quit = 1;
  442. return;
  443. }
  444. error T("Timeout on Account Server, reconnecting...n"), "connection";
  445. $timeout_ex{'master'}{'time'} = time;
  446. $timeout_ex{'master'}{'timeout'} = $timeout{'reconnect'}{'timeout'};
  447. $self->serverDisconnect;
  448. undef $conState_tries;
  450. } elsif ($conState == 1.5) {
  452. if (!$self->serverAlive) {
  453. $self->setState(Network::NOT_CONNECTED);
  454. undef $conState_tries;
  455. return;
  456. }
  458. # on this special stage, the plugin will know what to do next.
  459. Plugins::callHook("Network::serverConnect/special");
  461. } elsif ($conState == 2 && !$self->serverAlive()
  462.   && ($config{'server'} ne "" || $masterServer->{charServer_ip})
  463.   && !$conState_tries) {
  464. if ($config{pauseCharServer}) {
  465. message "Pausing for $config{pauseCharServer} second(s)...n", "system";
  466. sleep $config{pauseCharServer};
  467. }
  468. my $master = $masterServer;
  469. message T("Connecting to Character Server...n"), "connection";
  470. $conState_tries++;
  472. if ($master->{charServer_ip}) {
  473. $self->serverConnect($master->{charServer_ip}, $master->{charServer_port});
  474. } elsif ($servers[$config{'server'}]) {
  475. $self->serverConnect($servers[$config{'server'}]{'ip'}, $servers[$config{'server'}]{'port'});
  476. } else {
  477. error TF("Invalid server specified, server %s does not exist...n", $config{server}), "connection";
  479. my @serverList;
  480. foreach my $server (@servers) {
  481. push @serverList, $server->{name};
  482. }
  483. my $ret = $interface->showMenu(
  484. T("Please select your login server."),
  485. @serverList,
  486. title => T("Select Login Server"));
  487. if ($ret == -1) {
  488. quit();
  489. } else {
  490. main::configModify('server', $ret, 1);
  491. undef $conState_tries;
  492. }
  493. return;
  494. }
  496. # call plugin's hook to determine if we can continue the connection
  497. if ($self->serverAlive) {
  498. Plugins::callHook("Network::serverConnect/char");
  499. $reconnectCount = 0;
  500. return if ($conState == 1.5);
  501. }
  503. $messageSender->sendGameLogin($accountID, $sessionID, $sessionID2, $accountSex);
  504. $timeout{'gamelogin'}{'time'} = time;
  506. } elsif ($conState == 2 && timeOut($timeout{'gamelogin'})
  507.   && ($config{'server'} ne "" || $masterServer->{'charServer_ip'})) {
  508. error T("Timeout on Character Server, reconnecting...n"), "connection";
  509. $timeout_ex{'master'}{'time'} = time;
  510. $timeout_ex{'master'}{'timeout'} = $timeout{'reconnect'}{'timeout'};
  511. $self->serverDisconnect;
  512. undef $conState_tries;
  513. $self->setState(Network::NOT_CONNECTED);
  515. } elsif ($conState == 3 && !$self->serverAlive() && $config{'char'} ne "" && !$conState_tries) {
  516. message T("Connecting to Character Select Server...n"), "connection";
  517. $conState_tries++;
  518. $self->serverConnect($servers[$config{'server'}]{'ip'}, $servers[$config{'server'}]{'port'});
  520. # call plugin's hook to determine if we can continue the connection
  521. if ($self->serverAlive) {
  522. Plugins::callHook("Network::serverConnect/charselect");
  523. return if ($conState == 1.5);
  524. }
  526. $messageSender->sendCharLogin($config{'char'});
  527. $timeout{'charlogin'}{'time'} = time;
  529. } elsif ($conState == 3 && timeOut($timeout{'charlogin'}) && $config{'char'} ne "") {
  530. error T("Timeout on Character Select Server, reconnecting...n"), "connection";
  531. $timeout_ex{'master'}{'time'} = time;
  532. $timeout_ex{'master'}{'timeout'} = $timeout{'reconnect'}{'timeout'};
  533. $self->serverDisconnect;
  534. $self->setState(Network::NOT_CONNECTED);
  535. undef $conState_tries;
  537. } elsif ($conState == 4 && !$self->serverAlive() && !$conState_tries) {
  538. if ($config{pauseMapServer}) {
  539. message "Pausing for $config{pauseMapServer} second(s)...n", "system";
  540. sleep($config{pauseMapServer});
  541. }
  542. message T("Connecting to Map Server...n"), "connection";
  543. $conState_tries++;
  544. main::initConnectVars();
  545. my $master = $masterServer;
  546. my ($ip, $port);
  547. if ($master->{private}) {
  548. $ip = $config{forceMapIP} || $master->{ip};
  549. $port = $map_port;
  550. } else {
  551. $ip = $master->{mapServer_ip} || $config{forceMapIP} || $map_ip;
  552. $port = $master->{mapServer_port} || $map_port;
  553. }
  554. $self->serverConnect($ip, $port);
  556. # call plugin's hook to determine if we can continue the connection
  557. if ($self->serverAlive) {
  558. Plugins::callHook("Network::serverConnect/mapserver");
  559. return if ($conState == 1.5);
  560. }
  562. $messageSender->sendMapLogin($accountID, $charID, $sessionID, $accountSex2);
  563. $timeout_ex{master}{time} = time;
  564. $timeout_ex{master}{timeout} = $timeout{reconnect}{timeout};
  565. $timeout{maplogin}{time} = time;
  567. } elsif ($conState == 4 && timeOut($timeout{maplogin})) {
  568. message T("Timeout on Map Server, connecting to Account Server...n"), "connection";
  569. $timeout_ex{master}{timeout} = $timeout{reconnect}{timeout};
  570. $self->serverDisconnect;
  571. $self->setState(Network::NOT_CONNECTED);
  572. undef $conState_tries;
  574. } elsif ($conState == 5 && !$self->serverAlive()) {
  575. Plugins::callHook('disconnected');
  576. if ($config{dcOnDisconnect}) {
  577. chatLog("k", T("*** You disconnected, auto quit! ***n"));
  578. error T("Disconnected from Map Server, exiting...n"), "connection";
  579. $quit = 1;
  580. } else {
  581. error TF("Disconnected from Map Server, connecting to Account Server in %s seconds...n", $timeout{reconnect}{timeout}), "connection";
  582. $timeout_ex{master}{time} = time;
  583. $timeout_ex{master}{timeout} = $timeout{reconnect}{timeout};
  584. $self->setState(Network::NOT_CONNECTED);
  585. undef $conState_tries;
  586. }
  588. } elsif ($conState == 5 && timeOut($timeout{play})) {
  589. error T("Timeout on Map Server, "), "connection";
  590. Plugins::callHook('disconnected');
  591. if ($config{dcOnDisconnect}) {
  592. error T("exiting...n"), "connection";
  593. $quit = 1;
  594. } else {
  595. error TF("connecting to Account Server in %s seconds...n", $timeout{reconnect}{timeout}), "connection";
  596. $timeout_ex{master}{time} = time;
  597. $timeout_ex{master}{timeout} = $timeout{reconnect}{timeout};
  598. $self->serverDisconnect;
  599. $self->setState(Network::NOT_CONNECTED);
  600. undef $conState_tries;
  601. }
  602. }
  603. }
  605. return 1;