erlang 分布式控制

测试记录：

 

 

zdx@couchdb:~$ erl -sname 1 -setcookie 123
Erlang R13B03 (erts-5.7.4) [source] [rq:1] [async-threads:0] [hipe] [kernel-poll:false]

Eshell V5.7.4  (abort with ^G)
(1@couchdb)1> nodes().
[]
(1@couchdb)2> net_adm:ping(2).
** exception error : no function clause matching net_adm:ping(2)
(1@couchdb)3> node().
'1@couchdb'
(1@couchdb)4> nodes().
[]
(1@couchdb)5> net_adm:ping(2@couchdb).
* 1: syntax error before: '@'
(1@couchdb)5> net_adm:ping('2@couchdb').
pong
(1@couchdb)6> nodes().
['2@couchdb']
(1@couchdb)7>
User switch command
 -->
 --> j
   1* {shell,start,[init]}
 --> j
   1* {shell,start,[init]}
 --> h

 --> s
 --> s shell
 --> s [shell]
Unknown command
 --> s shell
 --> j
   1  {shell,start,[init]}
   2  {shell,start,[]}
   3  {shell,start,[]}
   4* {shell,start,[]}
 --> j
   1  {shell,start,[init]}
   2  {shell,start,[]}
   3  {shell,start,[]}
   4* {shell,start,[]}
 --> c 2
Eshell V5.7.4  (abort with ^G)
(
 --> j
   1  {shell,start,[init]}
   2* {shell,start,[]}
   3  {shell,start,[]}
   4  {shell,start,[]}
 --> c 2

(1@couchdb)2> nodes().
['2@couchdb','3@couchdb']
(1@couchdb)3> net_adm:ping('4@couchdb').
pong
(1@couchdb)4> nodes().
['2@couchdb','3@couchdb','4@couchdb']
(1@couchdb)5>

 

 

 

 

zdx@couchdb:~$ erl -sname 2 -setcookie 123
Erlang R13B03 (erts-5.7.4) [source] [rq:1] [async-threads:0] [hipe] [kernel-poll                                              :false]

Eshell V5.7.4  (abort with ^G)
(2@couchdb)1> nodes().
['1@couchdb']
(2@couchdb)2>
User switch command

 --> j
   1* {shell,start,[init]}
 --> j
   1* {shell,start,[init]}
 --> c 1

(2@couchdb)2> nodes().
['1@couchdb']

(2@couchdb)3>
User switch command
 --> r '1@couchdb'
 -->  r '1@couchdb' shell
 --> j
   1  {shell,start,[init]}
   2  {'1@couchdb',shell,start,[]}
   3* {'1@couchdb',shell,start,[]}
 --> c 2
Eshell V5.7.4  (abort with ^G)
(1@couchdb)1>

 

 

zdx@couchdb:~$ erl -remsh '1@couchdb' -sname 3 -setcookie 123
Erlang R13B03 (erts-5.7.4) [source] [rq:1] [async-threads:0] [hipe] [kernel-poll                                              :false]

Eshell V5.7.4  (abort with ^G)
(1@couchdb)1 > G
(1@couchdb)1>
User switch command
 -->

 --> j
   1* {'1@couchdb',shell,start,[]}
 -->

 

 

 

 

 

(1@couchdb)4> nodes().
['2@couchdb','3@couchdb','4@couchdb']
(1@couchdb)5>
User switch command
 --> j
   1  {shell,start,[init]}
   2* {shell,start,[]}
   3  {shell,start,[]}
   4  {shell,start,[]}

 --> r 4@couchdb
Unknown command
 --> r '4@couchdb'
 --> j
   1  {shell,start,[init]}
   2  {shell,start,[]}
   3  {shell,start,[]}
   4  {shell,start,[]}
   5* {'4@couchdb',shell,start,[]}
 --> c 5
Eshell V5.7.4  (abort with ^G)
(4@couchdb)1>

 

 

 

zdx@couchdb:~$ erl -sname 4 -setcookie 123 -detached
zdx@couchdb:~$ erl -setcookie 123
Erlang R13B03 (erts-5.7.4) [source] [rq:1] [async-threads:0] [hipe] [kernel-poll:false]

Eshell V5.7.4  (abort with ^G)
1> nodes().
[]
2> net_adm:ping().
** exception error: undefined function net_adm:ping/0
3> net_adm:ping('1@couchdb').
pang
4> nodes().
[]
5> net_adm:ping('nonode@nohost').
pang
6>

评论

1 楼 zdx3578 2012-02-02  

首先需要将虚拟机的名字改好，各种能想到的地方都需要改好，包括本地的和dns中的
好像还需要在exchange那边配置写什么东西才可以让新的linux上的p3s节点连接进去
防火墙中打开4369端口供epmd通信用，据说tcp、udp都要打开
从其他linux机器上将原文件copy过来，切记要按照原linux上的路径建立文件夹，包括建立log、db、queue文件夹，因为我忘了是否会自动建立，所以还是自己手工建起来
在程序路径下有sbin/p3s节点的启动脚本，启动后是在后台运行的，可以通过ps等方式，或者可以想到的方式查看是否成功起来
sbin目录中还有个manage的管理节点，他可以用来管理在后台运行的节点。
将mangae节点起来后，按ctrl+g键可以进入一种不知道叫什么的控制界面
使用r ‘p3s@XXXX'可以创建一个新的shell
使用j命令可以查看当前有哪几个shell
使用c 【shell的序号】就可以attached到需要控制的那个shell中
attached进去后对于新的p3s节点要先将自己添加到集群中
然后copy一些数据库过来包括schema、sq_pending_queue、sq_sending_queue等等
然后再手工启动sq_p3s:start().
正确起来后再使用ctrl+g回到原先的控制界面中
j查看shell序列号，使用k 【shell序列号】将先前用r创建的shell杀掉
然后连接回manage的shell，q()退出manage节点
顺利的话这些步骤应该就能完成启动目的

我原先在sq_utils里边还是哪个文件里边写了个可以设置p3s最大允许处理的任务数的函数，具体名字我不太记得了
查看一些应该就能知道Linux下边设置为16个或者32个，暂时不要设置的太大了，以免有什么问题

smtp节点还没有在linux上成功工作过，这似乎是个隐患