有关网际互连的一篇文章

[Odysseus]

作者:jjgod　　发表时间:2001年4月15日 08:24

--------------------------------------------------------------------------------

发信人: fof (格斗之迷～思考中), 信区: wiz
标 题: 侃侃网络精灵（DNS_MASTER）（续）
发信站: 交大兵马俑BBS站 (Tue Dec 5 19:45:55 2000), 转信

Happy 的玩家应该有这个印象吧：有一段时间，敲一个 mudlist -a 命令，看
到了
好几屏的 MUD 服务器列表，大小都有，中英文也都有，真是五花八门，乱七八糟，
眼睛都看花了，:-(
我不知道这种现象能说明多少问题，我只提一点，就是 Happy 当时的名气应该是
蛮大的吧，许多未曾谋面的 MUD 自愿将 Happy 加入到自己的网际互联列表中，
使 Happy 的网上邻居异常地多起来；狮子(Lion)的 Hero 更牛，最先就是从 Hero
看到英文 MUD 互联进来的，海外关系不错嘛，hoho。当然了，网际互联的增多造
成了一些混乱现象没有得到很好的处理，是我们管理员的失职，这个以后再谈。
我想说说那一长串的网际互联 MUD 列表是怎么来的。
以往要实现两个 MUD 的互联，必须两个 MUD 都各自将对方加入自己的网际互联
配置列表中，具体是 /include/net/config.h 中定义的 LISTNODES 常量：
#define LISTNODES ([ \
"happy": "202.117.7.54 6670", \
"hero": "202.117.7.55 3378", \
])
数据是映射（mapping）类型的，"happy"、"hero" 是对方 MUD 的网上名称，
"202.117.7.54"、"202.117.7.55" 是对方 MUD 的地址，"6670"、"3378" 是对方
MUD 的 UDP 端口（UDP 是建立于无连接基础上的网络通信协议，与 TCP 协议是
相对的，TCP 是建立于连接基础上的网络通信协议），当两个 MUD 建立了网际互
联之后，双方就各自向对方的 UDP 端口发送报文，就像通过邮局寄信一样。一般
来说，XYJ 和 XKX 类 MUD 的 UDP 为游戏端口加 4 ，FY 类 MUD 的 UDP 为游戏
端口加 45 ，就像上面那两个：6666 + 4 = 6670 ，3333 + 45 = 3378
另外，"happy"、"hero" 等 MUD 的网上名称是定义在 /include/mudlib.h 中的：
#define INTERMUD_MUD_NAME "TEST"
这个头文件中还定义了其他一些信息，如 MUD 的中文名称啦、版本啦等等，但
不是 DNS_MASTER 跑起来所必须的东西。
看看 DNS_MASTER 的运行：
DNS_MASTER 被载入内存或被 update 的时候当即就开始工作了，因此可以推断
出 DNS_MASTER 中有 create() 函数，因为 create() 函数就是在那两种情况下
被自动执行的。看看这个 create() 函数是怎么写的：
void create()
{
mapping static_db;
int i, j;
string *list;
string *strs;
string ip, port, *listkey;
restore_euid();
set("channel_id", "网路精灵");
//added by mon 10/23/97
list = values(LISTNODES); //从 LISTNODES 中取得要互联的 MUD 的信息

listkey = keys(LISTNODES);
j = sizeof(list);
muds_ip = ({});
muds_port = ({});
muds_name = ({});
if( j > 0 )
for( i = 0; i < j; i ++ ) {
if( sscanf(list[i], "%s %s", ip, port) == 2 ) {
muds_ip += ({ ip });
muds_port += ({ port });
muds_name += ({ htonn(listkey[i]) });
} //最终所有将要互联的 MUD 的信息都存储在 muds_ip、muds_po
rt、
} //muds_name 这三个全局变量中（注意：是将要互联而不
是已经联上）

// find out which port we are on 找出自己的 UDP（GamePort + 4）
my_port = SRVC_PORT_UDP(mud_port());
// initialise global mud info variables
muds = allocate_mapping(MUDS_ALLOC);// muds 这个变量才是已经联上的
MUD 信息
mud_svc = allocate_mapping(MUDS_ALLOC);
// initialise the sequencing variables
seq_ctr = 0;
seq_entries = ([]);
// set the bootserver default
bootsrv = MUDLIST_DNS;
bootsrv_retry = 0;
// tell the mudlist_a daemon that we have cleared the database
MUDLIST_A->clear_db_flag();
// set up our own info 设置自己的信息
this_host = ([
"MUDNAME" : INTERMUD_NAME,
"NAME" : Mud_name(),
"ALIAS" : Mud_name(),
"MUDLIB" : MUDLIB_NAME,
"VERSION" : MUDLIB_VERSION,
"HOST" : query_host_name(),
"HOSTADDRESS" : 0, // set in resolve_callback()
"PORT" : "" + mud_port(),
"PORTUDP" : "" + my_port,
"TIME" : ctime(time()),
"TCP" : TCP_SERVICE_LEVEL,
"USERS" : ""+sizeof(users()),
]);
resolve(query_host_name(), "resolve_callback");
// initialise the udp socket, if successful start the database system
//初始化 UDP Socket ，Socket 是通信的基础，数据的发送和接收都靠它
if (startup_udp()) init_database();
}
接着看 startup_udp() 函数：
int startup_udp()
{
int err_no;
if (socket_id) return 0;
//调用 socket_create() 函数来创建一个 socket
socket_id = socket_create(DATAGRAM, "read_callback", "close_callba
ck");
if (socket_id < 0) {
log("Failed to acquire socket.\n");
return 0;
}
err_no = socket_bind(socket_id, my_port);
while( err_no == EEADDRINUSE ) {
my_port++;
err_no = socket_bind(socket_id, my_port);
}
if( err_no <= 0 ) {
log( sprintf("Failed to bind socket of UDP services, error = %d.\n",

err_no));
socket_close(socket_id);
return 0;
}
return 1;
}
socket_create() 是一个外部定义函数（e_fun），是写在 MUDOS 里的，因此不
要到
哪个文件里找它的定义，只要看看它是怎么用的（敲 help create_socket 命令
或打开文件 /doc/efuns/socket_create 文件）：
…………
#include <socket_err.h>
int socket_create( int mode, string read_callback,
void | string close_callback );
socket_create() creates an efun socket. mode determines
which type of socket is created. Currently supported socket
modes are:
MUD for sending LPC data types using TCP protocol.
STREAM for sending raw data using TCP protocol.
DATAGRAM for using UDP protocol. 数据报类型
The argument read_callback is the name of a function for the
driver to call when the socket gets data from its peer. The
read callback should follow this format:
void read_callback(int fd, mixed message)
Where fd is the socket which received the data, and message
is the data which was received.
The argument close_callback is the name of a function for
the driver to call if the socket closes unexpectedly, i.e.
not as the result of a socket_close(3) call. The close
callback should follow this format:
void close_callback(int fd)
Where fd is the socket which has closed. NOTE:
close_callback is not used with DATAGRAM mode sockets.
…………
调用 socket_create() 函数的时候，要求三个参数，第一个是 socket 的类型，

第二个是 socket 收到数据时执行的函数，第三个是 socket 异常关闭时执行的
函数。注意，这里说的这两个函数都不是外部定义函数，而是我们可以编程控制
的函数。Well ，我们就来控制一下 socket 收到数据时要执行的东西：
// this is called when we receive a udp packet. We determine which
// service the packet is for, and send it to the auxiliary daemon of
// that name
void read_callback(int sock, string msg, string addr)
{ //^^^这个 msg 就是接收到的数据了
string func, rest="", *bits, name, arg;
//initialize rest string. mon 10/20/97
mapping args;
int i;
//if(previous_object()) return;
debug("DNS: Got " + msg);
// get the function from the packet
// 提取 packet（包）中的 function ，这里要说明一下这种“包”的数据
结构：
// 首先，包以三个 "@" 起头，又以三个 "@" 结尾，中间的数据按照类型分成
// 若干块，块与块之间用两个 "|" 隔开，第一个块固定为包的功能，或者说
// 是包的类型，这些功能（类型）有：startup、mudlist_q、mudlist_a等等，
// 与目录 /adm/daemons/network/services/ 下的一个个文件是对应的
if( !sscanf(msg, "@@@%s||%s@@@%*s", func, rest)) {
if (!sscanf(msg, "@@@%s@@@%*s", func)) return;
rest = ""; //数据的格式必须正确，function 也是必须有的，否则就
return ，
} //不往下执行，避免收到非 MUD 互联的信息时误认为是
MUD 互联信息

// get the address(remove port number)
sscanf(addr, "%s %*s", addr);
// get the arguments to the function
// these are in the form "<arg>:<value>" and are put into a mapping
// like that
if( strlen(rest) < 2 ) return;
//mon 10/20/97 to prevent crash in explode.
//哈哈，mon 早就知道 explode 会使 MUD crash ，干嘛不早告诉我们呢？


bits = explode(rest, "||");
args = allocate_mapping(sizeof(bits)+3);//"+3" by mon 10/19/97
//for NAME, ...
i = sizeof(bits);
while (i--) //将前面提到的一个个块提出，存入一个 mapping 变量中
if (bits[i] && sscanf(bits[i], "%s:%s", name, arg) == 2)
args[name] = arg;
args["HOSTADDRESS"] = addr;
// some muds don 't send their name out in a network friendly form
if (args["NAME"]) {
args["NAME"]= htonn(args["NAME"]);
//mon 1/14/98
args["ALIAS"] = htonn(args["NAME"]);
}
//added by mon 10/23/97
if( !check_mud(addr, "", "") ) { //only check IP as port may missing.
/*
log_file("dns_master",ctime(time())+
" Unwanted message from:"+
(undefinedp(args["HOSTADDRESS"])?"unknown_host":args["HOSTADDRESS"])
+
" "+
(undefinedp(args["PORTUDP"])?"unknown_port":args["PORTUDP"])+"\n");
*/
return; //check_mud() 不成功的时候，函数将不往下执行
} //check_mud() 干了些什么呢？

// we have received a message from someone, so we clear their
// no contact count 收到了一个 MUD 发来的信息，当然要清除“失去联络”标记了
if (mapp(muds[args["NAME"]]))
muds[args["NAME"]][DNS_NO_CONTACT] = 0;
//update TIME and USERS info for this mud.
//mon 1/8/98
debug("DNS: got message " + mapp(muds[args["NAME"]]) +
" " + args["NAME"] + "\n");
//args["NAME"]是当前收到的包含在数据包中的 MUD 名称，即发出信息的
MUD
//的名称，mapp(muds[args["NAME"]])则是看已经联上的 MUD 中有没有这个名
//称，如果有的话，就更新这个 MUD 的 "TIME" 和 "USERS" 信息
if (mapp(muds[args["NAME"]])) {
if(!undefinedp(args["TIME"]) && args["TIME"])
//TIME field exist and non-trivial.

*************文章太长了，待续...*************