{"id":1071,"date":"2006-06-21T19:00:00","date_gmt":"2006-06-22T02:00:00","guid":{"rendered":"http:\/\/kodegeek.com\/blog\/?p=1071"},"modified":"2011-02-28T18:44:51","modified_gmt":"2011-03-01T01:44:51","slug":"echando-codigo-%c2%bfmonitoreando-servicios-rpc-usando-java-onc-rpc-y-el-protocolo-jabber-i","status":"publish","type":"post","link":"http:\/\/kodegeek.com\/blog\/2006\/06\/21\/echando-codigo-%c2%bfmonitoreando-servicios-rpc-usando-java-onc-rpc-y-el-protocolo-jabber-i\/","title":{"rendered":"Echando c\u00f3digo: \u00bfMonitoreando servicios RPC usando Java, ONC RPC y el protocolo Jabber? (I)"},"content":{"rendered":"

\"Java<\/a>
\nLa sabiduria de los taxistas<\/a><\/p>\n

\u00bfQue diria usted si yo le dijera que es posible hacer un sistema de monitoreo usando Java<\/a>, ONCR RPC<\/a> y el protocolo Jabber<\/a>? Es mucho m\u00e1s sencillo de lo que usted cree y es algo que siempre quise hacer en la compa\u00f1ia en la cual trabajaba anteriormente (en la actual estoy trabajando similar, pero mucho m\u00e1s sofisticado :D) y nunca tuve tiempo de hacer.<\/p>\n

Pero bueno, demasiada habladera de paja, veamos que hay que poner en orden:<\/p>\n

    \n
  1. Asumimos que los servicios que queremos monitorear se basan en ONRC RPC. Ejemplo de ellos son NIS, NFS, Rusers, Rquota<\/span> y en nuestro caso Rstatd<\/span> que aunque es muchisimo m\u00e1s limitado que SNMP<\/a> est\u00e1 presente en muchos servidores, corriendo de gr\u00e1tis \ud83d\ude42<\/li>\n
  2. ONRC RPC tiene unos archivos que describen como usar los servicios remoto, llamados ‘stubs’. Si alguna vez ha utilizado RMI <\/a>el concepto le ser\u00e1 familiar. Pero hay un problema, los ‘stubs’ son muy similares a el lenguaje C, por lo que necesitamos una herramienta que nos sirva como puente. Para ello usamos el compilador de remote tea: jrpcgen.jar<\/span>.<\/li>\n
  3. Una vez obtenidos las interfaces y clientes en Java entonces las compilamos y nos valemos de las librerias de comunicaci\u00f3n provistas por remote tea (onrpc.jar<\/span>).<\/li>\n
  4. De all\u00ed armamos los programas que van a hacer la consulta por medio de RPC. Luego nos preocupamos de como enviar los datos usando Jabber.<\/li>\n<\/ol>\n

    Lo primero que hay que hacer es generar las interfaces. El precompilador jrpcgen no tiene una tarea de Ant, sin embargo nosotros nos valemos de un macro<\/a> con el cual preparamos las fuentes. Note que primero limpiamos los archivos ‘.x’ utilizando al precompilador cpp y es all\u00ed cuando podemos usar a jrpcgen.<\/p>\n

    El macro en Ant es muy sencillo:
    \n
    \n–><\/p>\n

     <\/p>\n

    62:<\/span>        <!--<\/span> <\/span>Special<\/span> <\/span>macro<\/span> <\/span>to<\/span> <\/span>enable<\/span> <\/span>the<\/span> <\/span>RPC<\/span> <\/span>stub<\/span> <\/span>generation<\/span> <\/span>--><\/span>\r\n63:<\/span>        <<\/span>macrodef<\/span> <\/span>name<\/span>=<\/span>\"<\/span>rpcgen<\/span>\"<\/span>><\/span>\r\n64:<\/span>                <<\/span>attribute<\/span> <\/span>name<\/span>=<\/span>\"<\/span>xfile<\/span>\"<\/span>\/<\/span>><\/span>\r\n65:<\/span>                <<\/span>attribute<\/span> <\/span>name<\/span>=<\/span>\"<\/span>clientJavaFile<\/span>\"<\/span>\/<\/span>><\/span>\r\n66:<\/span>                <<\/span>sequential<\/span>>\r\n<\/span>67:<\/span>                        <!--<\/span> <\/span>Preprocess<\/span> <\/span>the<\/span> <\/span>'x'<\/span> <\/span>files<\/span> <\/span>--><\/span>\r\n68:<\/span>                        <<\/span>exec<\/span>\r\n<\/span>69:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>executable<\/span>=<\/span>\"<\/span>\/usr\/bin\/cpp<\/span>\"<\/span>><\/span>\r\n70:<\/span>                                <<\/span>arg<\/span> <\/span>line<\/span>=<\/span>\"<\/span>${rpc.include.local}\/@{xfile}.x<\/span>\"<\/span>\/<\/span>><\/span>\r\n71:<\/span>                                <<\/span>arg<\/span> <\/span>line<\/span>=<\/span>\"<\/span>${rpc.include.local}\/@{xfile}.cpp<\/span>\"<\/span>\/<\/span>>\r\n<\/span>72:<\/span>                        <<\/span>\/<\/span>exec<\/span>><\/span>\r\n73:<\/span>                        <!--<\/span> <\/span>Cleanup<\/span> <\/span>remaining<\/span> <\/span>artifacts<\/span> <\/span>--><\/span>\r\n74:<\/span>                        <<\/span>replaceregexp<\/span> <\/span>\r\n75:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>file<\/span>=<\/span>\"<\/span>${rpc.include.local}\/@{xfile}.cpp<\/span>\"<\/span>\r\n76:<\/span>        <\/span>        <\/span>        <\/span> <\/span> <\/span> <\/span> <\/span>match<\/span>=<\/span>\"<\/span>^#<\/span>\"<\/span>\r\n77:<\/span>        <\/span>        <\/span>        <\/span> <\/span> <\/span> <\/span> <\/span>replace<\/span>=<\/span>\"<\/span>\/\/<\/span>\"<\/span>\r\n78:<\/span>        <\/span>        <\/span>        <\/span> <\/span> <\/span> <\/span> <\/span>byline<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>\/<\/span>><\/span>\r\n79:<\/span>                        <!--<\/span> <\/span>generate<\/span> <\/span>the<\/span> <\/span>Java<\/span> <\/span>classes<\/span> <\/span>--><\/span>\r\n80:<\/span>                        <<\/span>java<\/span>\r\n81:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>classname<\/span>=<\/span>\"<\/span>org.acplt.oncrpc.apps.jrpcgen.jrpcgen<\/span>\"\r\n<\/span>82:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>dir<\/span>=<\/span>\"<\/span>${rpc.include.local}<\/span>\"<\/span>\r\n83:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>fork<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>><\/span>\r\n84:<\/span>                                <<\/span>classpath<\/span> <\/span>refid<\/span>=<\/span>\"<\/span>path.classpath<\/span>\"<\/span>\/<\/span>><\/span>\r\n85:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-p<\/span>\"<\/span>\/<\/span>>\r\n<\/span>86:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>${package.tree}<\/span>\"<\/span>\/<\/span>>\r\n<\/span>87:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-nobackup<\/span>\"<\/span>\/<\/span>><\/span>\r\n88:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-noserver<\/span>\"<\/span>\/<\/span>><\/span>\r\n89:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-verbose<\/span>\"<\/span>\/<\/span>><\/span>\r\n90:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-withcallinfo<\/span>\"<\/span>\/<\/span>><\/span>\r\n91:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-bean<\/span>\"<\/span>\/<\/span>><\/span>\r\n92:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-c<\/span>\"<\/span>\/<\/span>><\/span>\r\n93:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>@{clientJavaFile}<\/span>\"<\/span>\/<\/span>>\r\n<\/span>94:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>-d<\/span>\"<\/span>\/<\/span>><\/span>\r\n95:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>${stub}<\/span>\"<\/span>\/<\/span>>\r\n<\/span>96:<\/span>                                <<\/span>arg<\/span> <\/span>value<\/span>=<\/span>\"<\/span>@{xfile}.cpp<\/span>\"<\/span>\/<\/span>><\/span>\r\n97:<\/span>                        <<\/span>\/<\/span>java<\/span>>\r\n<\/span>98:<\/span>                <<\/span>\/<\/span>sequential<\/span>><\/span>\r\n99:<\/span>        <<\/span>\/<\/span>macrodef<\/span>><\/span><\/pre>\n
    Una vez definido llamarlo es muy sencillo (note que primero generamos el c\u00f3digo Java de las interfaces y luego m\u00e1s delante compilamos el c\u00f3digo de la aplicaci\u00f3n junto con el de las interfaces):
    \n
    \n–><\/p>\n
     <\/p>\n
    101:<\/span>        <<\/span>target<\/span>\r\n<\/span>102:<\/span>        <\/span>        <\/span>name<\/span>=<\/span>\"<\/span>rpcstub<\/span>\"<\/span>\r\n103:<\/span>        <\/span>        <\/span>depends<\/span>=<\/span>\"<\/span>init<\/span>\"<\/span>\r\n104:<\/span>        <\/span>        <\/span>description<\/span>=<\/span>\"<\/span>Create<\/span> <\/span>the<\/span> <\/span>RPC<\/span> <\/span>Java<\/span> <\/span>stub<\/span> <\/span>objects<\/span>\"<\/span>><\/span>\r\n105:<\/span>                <<\/span>copy<\/span>\r\n<\/span>106:<\/span>        <\/span>        <\/span>        <\/span>todir<\/span>=<\/span>\"<\/span>${rpc.include.local}<\/span>\"<\/span>\r\n<\/span>107:<\/span>        <\/span>        <\/span>        <\/span>overwrite<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>>\r\n<\/span>108:<\/span>                        <<\/span>fileset<\/span> <\/span>dir<\/span>=<\/span>\"<\/span>${rpc.include.dir}<\/span>\"<\/span>>\r\n<\/span>109:<\/span>                                <<\/span>include<\/span> <\/span>name<\/span>=<\/span>\"<\/span>*.x<\/span>\"<\/span>\/<\/span>><\/span>\r\n110:<\/span>                                <<\/span>include<\/span> <\/span>name<\/span>=<\/span>\"<\/span>*.h<\/span>\"<\/span>\/<\/span>>\r\n<\/span>111:<\/span>                        <<\/span>\/<\/span>fileset<\/span>><\/span>\r\n112:<\/span>                <<\/span>\/<\/span>copy<\/span>><\/span>\r\n113:<\/span>                <<\/span>rpcgen<\/span> <\/span>xfile<\/span>=<\/span>\"<\/span>rstat<\/span>\"<\/span> <\/span>clientJavaFile<\/span>=<\/span>\"<\/span>RstatClient<\/span>\"<\/span>\/<\/span>>\r\n<\/span>114:<\/span>                <<\/span>rpcgen<\/span> <\/span>xfile<\/span>=<\/span>\"<\/span>mount<\/span>\"<\/span> <\/span>clientJavaFile<\/span>=<\/span>\"<\/span>MountClient<\/span>\"<\/span>\/<\/span>><\/span>\r\n115:<\/span>                <<\/span>rpcgen<\/span> <\/span>xfile<\/span>=<\/span>\"<\/span>nfs_prot<\/span>\"<\/span> <\/span>clientJavaFile<\/span>=<\/span>\"<\/span>NfsProtClient<\/span>\"<\/span>\/<\/span>><\/span>\r\n<\/span>116:<\/span>        <<\/span>\/<\/span>target<\/span>><\/span><\/pre>\n
    La compilaci\u00f3n no depende de la generaci\u00f3n de las interfaces ya que estas se guardan en CVS y si por algunas raz\u00f3n cambian es entonces que volver\u00e1n a ser creadas. Es decir, una vez creadas las interfaces solamente nos tenemos que preocupar por compilar:
    \n
    \n–><\/p>\n
     <\/p>\n
    118:<\/span>        <<\/span>target<\/span> <\/span>\r\n119:<\/span>        <\/span>        <\/span>name<\/span>=<\/span>\"<\/span>build<\/span>\"<\/span>\r\n<\/span>120:<\/span>        <\/span>        <\/span>depends<\/span>=<\/span>\"<\/span>init<\/span>\"<\/span>\r\n<\/span>121:<\/span>        <\/span>        <\/span>description<\/span>=<\/span>\"<\/span>Compile<\/span> <\/span>the<\/span> <\/span>Java<\/span> <\/span>source<\/span> <\/span>code<\/span>\"<\/span>>\r\n<\/span>122:<\/span>                <!--<\/span> <\/span>Compile<\/span> <\/span>the<\/span> <\/span>stub<\/span> <\/span>-->\r\n<\/span>123:<\/span>                <<\/span>javac<\/span> <\/span>\r\n124:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>srcdir<\/span>=<\/span>\"<\/span>${stub}<\/span>\"<\/span> <\/span>\r\n125:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>destdir<\/span>=<\/span>\"<\/span>${build}<\/span>\"<\/span> <\/span>\r\n126:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>deprecation<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span> <\/span>\r\n127:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>optimize<\/span>=<\/span>\"<\/span>false<\/span>\"<\/span>\r\n<\/span>128:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>debug<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>><\/span>\r\n129:<\/span>                                <<\/span>include<\/span> <\/span>name<\/span>=<\/span>\"<\/span>**\/*.java<\/span>\"<\/span>\/<\/span>>\r\n<\/span>130:<\/span>                                <<\/span>classpath<\/span> <\/span>refid<\/span>=<\/span>\"<\/span>path.classpath<\/span>\"<\/span>\/<\/span>><\/span>\r\n131:<\/span>                <<\/span>\/<\/span>javac<\/span>>\r\n<\/span>132:<\/span>                <!--<\/span> <\/span>Compile<\/span> <\/span>the<\/span> <\/span>app<\/span> <\/span>-->\r\n<\/span>133:<\/span>                <<\/span>javac<\/span> <\/span>\r\n134:<\/span>        <\/span>        <\/span>        <\/span>srcdir<\/span>=<\/span>\"<\/span>${src}\/main<\/span>\"<\/span> <\/span>\r\n135:<\/span>        <\/span>        <\/span>        <\/span>destdir<\/span>=<\/span>\"<\/span>${build}<\/span>\"<\/span>\r\n<\/span>136:<\/span>        <\/span>        <\/span>        <\/span>deprecation<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span> <\/span>\r\n137:<\/span>        <\/span>        <\/span>        <\/span>optimize<\/span>=<\/span>\"<\/span>false<\/span>\"<\/span> <\/span>\r\n138:<\/span>        <\/span>        <\/span>        <\/span>debug<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>>\r\n<\/span>139:<\/span>                        <<\/span>include<\/span> <\/span>name<\/span>=<\/span>\"<\/span>${package.path}\/**\/*.java<\/span>\"<\/span>\/<\/span>>\r\n<\/span>140:<\/span>                        <<\/span>classpath<\/span> <\/span>refid<\/span>=<\/span>\"<\/span>path.classpath<\/span>\"<\/span>\/<\/span>>\r\n<\/span>141:<\/span>                <<\/span>\/<\/span>javac<\/span>>\r\n<\/span>142:<\/span>                <<\/span>copy<\/span> <\/span>\r\n143:<\/span>        <\/span>        <\/span>        <\/span>todir<\/span>=<\/span>\"<\/span>${build}<\/span>\"<\/span> <\/span>\r\n144:<\/span>        <\/span>        <\/span>        <\/span>overwrite<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>>\r\n<\/span>145:<\/span>                        <<\/span>fileset<\/span> <\/span>dir<\/span>=<\/span>\"<\/span>${properties}\/main<\/span>\"<\/span>><\/span>\r\n146:<\/span>                                <<\/span>include<\/span> <\/span>name<\/span>=<\/span>\"<\/span>${package.path}\/**\/*.properties<\/span>\"<\/span>\/<\/span>><\/span>\r\n147:<\/span>                        <<\/span>\/<\/span>fileset<\/span>>\r\n<\/span>148:<\/span>                <<\/span>\/<\/span>copy<\/span>>\r\n<\/span>149:<\/span>                <<\/span>copy<\/span>\r\n<\/span>150:<\/span>        <\/span>        <\/span>        <\/span>todir<\/span>=<\/span>\"<\/span>${build}<\/span>\"<\/span> <\/span>overwrite<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>><\/span>\r\n151:<\/span>                        <<\/span>fileset<\/span> <\/span>dir<\/span>=<\/span>\"<\/span>.<\/span>\"<\/span>><\/span>\r\n152:<\/span>                                        <<\/span>include<\/span> <\/span>name<\/span>=<\/span>\"<\/span>log4j.properties<\/span>\"<\/span>\/<\/span>><\/span>\r\n153:<\/span>                        <<\/span>\/<\/span>fileset<\/span>>\r\n<\/span>154:<\/span>                <<\/span>\/<\/span>copy<\/span>>\r\n<\/span>155:<\/span>        <<\/span>\/<\/span>target<\/span>><\/span><\/pre>\n
    El siguiente paso es preparar las pruebas de unidad con Junit. Lo primero que hacemos es decirle a ant que es lo que queremos ejecutar y en que orden (si no est\u00e1 familiarizado con Junit, le recomiendo que busque una de las tantas referencias que hay en Internet):
    \n
    \n–><\/p>\n
     <\/p>\n
    205:<\/span>        <<\/span>target<\/span> <\/span>\r\n206:<\/span>        <\/span>        <\/span>name<\/span>=<\/span>\"<\/span>test<\/span>\"<\/span> <\/span>\r\n207:<\/span>        <\/span>        <\/span>depends<\/span>=<\/span>\"<\/span>build<\/span>\"<\/span>\r\n208:<\/span>        <\/span>        <\/span>description<\/span>=<\/span>\"<\/span>Unit<\/span> <\/span>tests<\/span>\"<\/span>><\/span>\r\n209:<\/span>                <<\/span>echo<\/span>><\/span>Running unit tests<<\/span>\/<\/span>echo<\/span>><\/span>\r\n210:<\/span>                <<\/span>javac<\/span> <\/span>\r\n211:<\/span>        <\/span>        <\/span>        <\/span>srcdir<\/span>=<\/span>\"<\/span>${src}\/test<\/span>\"<\/span>\r\n<\/span>212:<\/span>        <\/span>        <\/span>        <\/span>destdir<\/span>=<\/span>\"<\/span>${test}<\/span>\"<\/span> <\/span>\r\n213:<\/span>        <\/span>        <\/span>        <\/span>includes<\/span>=<\/span>\"<\/span>${package.path}\/**\/Test*<\/span>\"<\/span> <\/span>\r\n214:<\/span>        <\/span>        <\/span>        <\/span>deprecation<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>\r\n<\/span>215:<\/span>        <\/span>        <\/span>        <\/span>optimize<\/span>=<\/span>\"<\/span>false<\/span>\"<\/span>\r\n<\/span>216:<\/span>        <\/span>        <\/span>        <\/span>debug<\/span>=<\/span>\"<\/span>true<\/span>\"<\/span>><\/span>\r\n217:<\/span>                        <<\/span>classpath<\/span> <\/span>refid<\/span>=<\/span>\"<\/span>path.test<\/span>\"<\/span>\/<\/span>><\/span>\r\n218:<\/span>                <<\/span>\/<\/span>javac<\/span>>\r\n<\/span>219:<\/span>\r\n220:<\/span>                <<\/span>junit<\/span>\r\n<\/span>221:<\/span>        <\/span>        <\/span>        <\/span>fork<\/span>=<\/span>\"<\/span>yes<\/span>\"<\/span> <\/span>\r\n222:<\/span>        <\/span>        <\/span>        <\/span>printsummary<\/span>=<\/span>\"<\/span>on<\/span>\"<\/span>\r\n<\/span>223:<\/span>        <\/span>        <\/span>        <\/span>maxmemory<\/span>=<\/span>\"<\/span>300m<\/span>\"<\/span>><\/span>\r\n224:<\/span>                        <<\/span>classpath<\/span> <\/span>refid<\/span>=<\/span>\"<\/span>path.test<\/span>\"<\/span>\/<\/span>>\r\n<\/span>225:<\/span>                        <<\/span>formatter<\/span> <\/span>type<\/span>=<\/span>\"<\/span>xml<\/span>\"<\/span> <\/span>\/<\/span>><\/span>\r\n226:<\/span>                        <<\/span>formatter<\/span> <\/span>type<\/span>=<\/span>\"<\/span>plain<\/span>\"<\/span> <\/span>\/<\/span>>\r\n<\/span>227:<\/span>                        <!--<\/span>\r\n<\/span>228:<\/span>        <\/span>        <\/span>        <\/span>-<\/span> <\/span>As<\/span> <\/span>root,<\/span> <\/span>set<\/span> <\/span>the<\/span> <\/span>following<\/span> <\/span>property<\/span> <\/span>on<\/span> <\/span>the<\/span> <\/span>\/etc\/exports<\/span> <\/span>file:\r\n<\/span>229:<\/span>        <\/span>        <\/span>        <\/span>\/usr\/local\/src<\/span> <\/span>127.0.0.1\/255.0.0.0(insecure,ro)\r\n<\/span>230:<\/span>        <\/span>        <\/span>        <\/span>-<\/span> <\/span>Then:<\/span>\r\n231:<\/span>        <\/span>        <\/span>        <\/span>\/etc\/init.d\/nfs<\/span> <\/span>start<\/span>   <\/span>        <\/span>        <\/span>\r\n232:<\/span>        <\/span>        <\/span>        <\/span>--><\/span>\r\n233:<\/span>                        <<\/span>sysproperty<\/span> <\/span>\r\n234:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>key<\/span>=<\/span>\"<\/span>test.nfs.dir<\/span>\"<\/span> <\/span>\r\n235:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>value<\/span>=<\/span>\"<\/span>\/usr\/local\/src<\/span>\"<\/span>\/<\/span>><\/span>\r\n236:<\/span>\r\n237:<\/span>                        <<\/span>sysproperty<\/span> <\/span>\r\n238:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>key<\/span>=<\/span>\"<\/span>test.nfs.server<\/span>\"<\/span>\r\n<\/span>239:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>value<\/span>=<\/span>\"<\/span>localhost<\/span>\"<\/span>\/<\/span>><\/span>\r\n240:<\/span>               \r\n241:<\/span>                        <<\/span>sysproperty<\/span> <\/span>\r\n242:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>key<\/span>=<\/span>\"<\/span>test.rstat.server<\/span>\"<\/span> <\/span>\r\n243:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>value<\/span>=<\/span>\"<\/span>localhost<\/span>\"<\/span>\/<\/span>>\r\n<\/span>244:<\/span>               \r\n245:<\/span>                        <!--<\/span> <\/span>Wait<\/span> <\/span>35<\/span> <\/span>seconds<\/span> <\/span>--><\/span>\r\n246:<\/span>                        <<\/span>sysproperty<\/span> <\/span>\r\n247:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>key<\/span>=<\/span>\"<\/span>test.rstat.wait<\/span>\"<\/span> <\/span>\r\n248:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>value<\/span>=<\/span>\"<\/span>35000<\/span>\"<\/span>\/<\/span>><\/span>\r\n249:<\/span>               \r\n250:<\/span>                        <<\/span>test<\/span>\r\n<\/span>251:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>name<\/span>=<\/span>\"<\/span>${testcase}<\/span>\"<\/span> <\/span>\r\n252:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>todir<\/span>=<\/span>\"<\/span>${test}<\/span>\"<\/span> <\/span>\r\n253:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>if<\/span>=<\/span>\"<\/span>testcase<\/span>\"<\/span>\/<\/span>><\/span>\r\n254:<\/span>\r\n255:<\/span>                        <<\/span>batchtest<\/span>\r\n<\/span>256:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>todir<\/span>=<\/span>\"<\/span>${test}<\/span>\"<\/span>\r\n<\/span>257:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>unless<\/span>=<\/span>\"<\/span>testcase<\/span>\"<\/span>><\/span>\r\n258:<\/span>                                <<\/span>fileset<\/span>\r\n<\/span>259:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>        <\/span>dir<\/span>=<\/span>\"<\/span>${test}<\/span>\"<\/span>\r\n<\/span>260:<\/span>        <\/span>        <\/span>        <\/span>        <\/span>        <\/span>includes<\/span>=<\/span>\"<\/span>**\/Test*.class<\/span>\"<\/span>\/<\/span>><\/span>\r\n261:<\/span>                        <<\/span>\/<\/span>batchtest<\/span>><\/span>   \r\n262:<\/span>                <<\/span>\/<\/span>junit<\/span>>\r\n<\/span>263:<\/span>       \r\n264:<\/span>                <<\/span>junitreport<\/span> <\/span>todir<\/span>=<\/span>\"<\/span>${test}<\/span>\"<\/span>><\/span>\r\n265:<\/span>                        <<\/span>fileset<\/span> <\/span>dir<\/span>=<\/span>\"<\/span>${test}<\/span>\"<\/span>><\/span>\r\n266:<\/span>                                <<\/span>include<\/span> <\/span>name<\/span>=<\/span>\"<\/span>TEST-*.xml<\/span>\"<\/span>\/<\/span>>\r\n<\/span>267:<\/span>                        <<\/span>\/<\/span>fileset<\/span>><\/span>\r\n268:<\/span>                        <<\/span>report<\/span> <\/span>format<\/span>=<\/span>\"<\/span>frames<\/span>\"<\/span> <\/span>todir<\/span>=<\/span>\"<\/span>${test}<\/span>\"<\/span>\/<\/span>>\r\n<\/span>269:<\/span>                <<\/span>\/<\/span>junitreport<\/span>><\/span>\r\n270:<\/span>        <<\/span>\/<\/span>target<\/span>><\/span><\/pre>\n
    Es entonces cuando podremos utilizar las clases cliente. Me gusta probar las cosas antes de ponerlas juntas, as\u00ed que escrib\u00ed algunas pruebas de unidad (Unit tests) <\/a>con JUnit<\/a> vemos que tan bien o mal est\u00e1n las clases generadas:
    \n
    \n–><\/p>\n
     <\/p>\n
    1:<\/span>package<\/span> com.kodegeek.blog.monitoring.rpc;\r\n2:<\/span>\r\n3:<\/span>import<\/span> java.net.InetAddress;\r\n4:<\/span>import<\/span> java.util.ResourceBundle;\r\n5:<\/span>\r\n6:<\/span>import<\/span> junit.framework.Assert;\r\n7:<\/span>import<\/span> junit.framework.TestCase;\r\n8:<\/span>\r\n9:<\/span>import<\/span> org.acplt.oncrpc.OncRpcClientAuthUnix;\r\n10:<\/span>import<\/span> org.acplt.oncrpc.OncRpcProtocols;\r\n11:<\/span>\r\n12:<\/span>public<\/span> class<\/span> TestRpcStubs extends<\/span> TestCase {<\/span>\r\n13:<\/span>\r\n14:<\/span>        \/**<\/span>\r\n15:<\/span>        <\/span> <\/span>*<\/span> <\/span>Default<\/span> <\/span>max<\/span> <\/span>timeout<\/span> <\/span>value<\/span>,<\/span> <\/span>in<\/span> <\/span>miliseconds<\/span>  \r\n16:<\/span>        <\/span> <\/span>*\/<\/span>  \r\n17:<\/span>        public<\/span> static<\/span> final<\/span> int<\/span> MAX_TIMEOUT =<\/span> 1000<\/span>*<\/span>60<\/span>;  \r\n18:<\/span>   \r\n19:<\/span>        private<\/span> static<\/span> ResourceBundle NFS_BUNDLE;  \r\n20:<\/span>        private<\/span> static<\/span> ResourceBundle RSTAT_BUNDLE;  \r\n21:<\/span>   \r\n22:<\/span>        {<\/span>  \r\n23:<\/span>                NFS_BUNDLE =<\/span> ResourceBundle.getBundle<\/span>(NfsPing.class<\/span>.getName<\/span>());  \r\n24:<\/span>                RSTAT_BUNDLE =<\/span> ResourceBundle.getBundle<\/span>(RstatPing.class<\/span>.getName<\/span>());  \r\n25:<\/span>        }<\/span>  \r\n26:<\/span>   \r\n27:<\/span>        protected<\/span> void<\/span> setUp<\/span>() throws<\/span> Exception {<\/span>  \r\n28:<\/span>                super<\/span>.setUp<\/span>();  \r\n29:<\/span>                System.out.println<\/span>(\"<\/span>Make<\/span> <\/span>sure<\/span> <\/span>all<\/span> <\/span>the<\/span> <\/span>services<\/span> <\/span>are<\/span> <\/span>running<\/span>\u00a0<\/span>with<\/span> <\/span>'\/usr\/sbin\/rpcinfo<\/span> <\/span>-p'<\/span>\"<\/span>);  \r\n30:<\/span>        }<\/span>  \r\n31:<\/span>   \r\n32:<\/span>        \/**<\/span>  \r\n33:<\/span>        <\/span> <\/span>*<\/span> <\/span>Simple<\/span> <\/span>test<\/span> <\/span>for<\/span> <\/span>the<\/span> <\/span>NFS<\/span> <\/span>client<\/span>,<\/span> <\/span>using<\/span> <\/span>the<\/span> <\/span>generated<\/span> <\/span>RPC<\/span> <\/span>stubs<\/span> <\/span>directly<\/span>  \r\n34:<\/span>        <\/span> <\/span>*<\/span>  \r\n35:<\/span>        <\/span> <\/span>*\/<\/span>  \r\n36:<\/span>        public<\/span> void<\/span> testNfs<\/span>() {<\/span>  \r\n37:<\/span>                MountClient mount =<\/span> null<\/span>;  \r\n38:<\/span>                exports exportsList =<\/span> null<\/span>;  \r\n39:<\/span>                fhstatus fhStatus =<\/span> null<\/span>;  \r\n40:<\/span>                OncRpcClientAuthUnix authUnix =<\/span> null<\/span>;  41:<\/span>                try<\/span> {<\/span>  42:<\/span>                        authUnix =<\/span> new<\/span> OncRpcClientAuthUnix<\/span>(  43:<\/span>                                        System.getProperty<\/span>(\"<\/span>test.nfs.server<\/span>\"<\/span>),  44:<\/span>                                        Integer.parseInt<\/span>(NFS_BUNDLE.getString<\/span>(\"<\/span>NfsPing.user.id<\/span>\"<\/span>)),  45:<\/span>                                        Integer.parseInt<\/span>(NFS_BUNDLE.getString<\/span>(\"<\/span>NfsPing.user.group<\/span>\"<\/span>))  46:<\/span>                        );  47:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Auth<\/span> <\/span>Unix<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, authUnix);  48:<\/span>                        \/\/<\/span> <\/span>Get<\/span> <\/span>the<\/span> <\/span>list<\/span> <\/span>of<\/span> <\/span>exported<\/span> <\/span>directories<\/span>  49:<\/span>                        mount =<\/span> new<\/span> MountClient<\/span>(  50:<\/span>                                        InetAddress.getByName<\/span>(System.getProperty<\/span>(\"<\/span>test.nfs.server<\/span>\"<\/span>)),  51:<\/span>                                        OncRpcProtocols.ONCRPC_TCP);  52:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Mount<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, mount);  53:<\/span>                        exportsList =<\/span> mount.MOUNTPROC_EXPORT_1<\/span>();  54:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Export<\/span> <\/span>list<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, exportsList);  55:<\/span>                        exportnode node =<\/span> exportsList.value;  56:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>No<\/span> <\/span>nodes<\/span> <\/span>are<\/span> <\/span>being<\/span> <\/span>exported<\/span>\"<\/span>, node);  57:<\/span>                        while<\/span> (node !<\/span>=<\/span> null<\/span>) {<\/span>  58:<\/span>                                Object [] nodeForm =<\/span> new<\/span> Object[1<\/span>];  59:<\/span>                                nodeForm[0<\/span>] =<\/span> node.ex_dir.value;  60:<\/span>                                System.out.printf<\/span>(  61:<\/span>                                                NFS_BUNDLE.getString<\/span>(\"<\/span>NfsPing.msg.exportedFs<\/span>\"<\/span>), nodeForm  62:<\/span>                                );  63:<\/span>                           64:<\/span>                                mount.getClient<\/span>().setAuth<\/span>(authUnix);  65:<\/span>                                mount.getClient<\/span>().setTimeout<\/span>(MAX_TIMEOUT);  66:<\/span>                           67:<\/span>                                fhStatus =<\/span> mount.MOUNTPROC_MNT_1<\/span>(new<\/span> dirpath<\/span>(System.getProperty<\/span>(\"<\/span>test.nfs.dir<\/span>\"<\/span>)));  68:<\/span>                                if<\/span> (fhStatus =<\/span>=<\/span> null<\/span>) {<\/span>  69:<\/span>                                        Assert.fail<\/span>(\"<\/span>unable<\/span> <\/span>to<\/span> <\/span>get<\/span> <\/span>fhStatus<\/span> <\/span>for:<\/span> <\/span>\"<\/span> +<\/span>System.getProperty<\/span>(\"<\/span>test.nfs.dir<\/span>\"<\/span>));  70:<\/span>                                }<\/span>  71:<\/span>                                \/\/<\/span> <\/span>Get<\/span> <\/span>the<\/span> <\/span>next<\/span> <\/span>node<\/span>  72:<\/span>                                node =<\/span> node.ex_next.value;  73:<\/span>                        }<\/span>  74:<\/span>                }<\/span> catch<\/span> (Throwable throwbl) {<\/span>  75:<\/span>                        Assert.fail<\/span>(\"<\/span>Got<\/span> <\/span>an<\/span> <\/span>exception:<\/span> <\/span>\"<\/span> +<\/span> throwbl.toString<\/span>());  76:<\/span>                        throwbl.printStackTrace<\/span>();  77:<\/span>                }<\/span> finally<\/span> {<\/span>  78:<\/span>                        \/\/<\/span> <\/span>Empty<\/span> <\/span>for<\/span> <\/span>now<\/span>  79:<\/span>                }<\/span>  80:<\/span>        }<\/span>  81:<\/span>  82:<\/span>        \/**<\/span>  83:<\/span>        <\/span> <\/span>*<\/span> <\/span>Simple<\/span> <\/span>test<\/span> <\/span>for<\/span> <\/span>Rstat<\/span>,<\/span> <\/span>using<\/span> <\/span>the<\/span> <\/span>generated<\/span> <\/span>RPC<\/span> <\/span>stubs<\/span> <\/span>directly<\/span>  84:<\/span>        <\/span> <\/span>*<\/span> <\/span>Timestamps<\/span> <\/span>are<\/span> <\/span>separated<\/span> <\/span>into<\/span> <\/span>seconds<\/span> <\/span>(<\/span>standard<\/span> <\/span>UNIX<\/span> <\/span>time<\/span>)<\/span> <\/span>and<\/span>  85:<\/span>        <\/span> <\/span>*<\/span> <\/span>microseconds<\/span>.<\/span> <\/span>The<\/span> <\/span>availability<\/span> <\/span>of<\/span> <\/span>a<\/span> <\/span>current<\/span> <\/span>timestamp<\/span> <\/span>allows<\/span> <\/span>proper<\/span>  86:<\/span>        <\/span> <\/span>*<\/span> <\/span>calculation<\/span> <\/span>of<\/span> <\/span>the<\/span> <\/span>interval<\/span> <\/span>between<\/span> <\/span>measurements<\/span> <\/span>without<\/span> <\/span>worrying<\/span>  87:<\/span>        <\/span> <\/span>*<\/span> <\/span>about<\/span> <\/span>network<\/span> <\/span>latency<\/span>.<\/span>  88:<\/span>        <\/span> <\/span>*<\/span> <\/span>  89:<\/span>        <\/span> <\/span>*<\/span> <\/span>Most<\/span> <\/span>values<\/span> <\/span>are<\/span> <\/span>counters<\/span>.<\/span> <\/span>To<\/span> <\/span>get<\/span> <\/span>the<\/span> <\/span>real<\/span> <\/span>numbers<\/span> <\/span>you<\/span> <\/span>have<\/span> <\/span>to<\/span>  90:<\/span>        <\/span> <\/span>*<\/span> <\/span>fetch<\/span>(<\/span>)<\/span> <\/span>samples<\/span> <\/span>regularly<\/span> <\/span>and<\/span> <\/span>divide<\/span> <\/span>the<\/span> <\/span>counter<\/span> <\/span>increments<\/span>  91:<\/span>        <\/span> <\/span>*<\/span> <\/span>by<\/span> <\/span>the<\/span> <\/span>time<\/span> <\/span>interval<\/span> <\/span>between<\/span> <\/span>the<\/span> <\/span>samples<\/span>.<\/span>  92:<\/span>        <\/span> <\/span>*<\/span>  93:<\/span>        <\/span> <\/span>*<\/span> <\/span>The<\/span> <\/span>cpu_time<\/span> <\/span>array<\/span> <\/span>holds<\/span> <\/span>the<\/span> <\/span>ticks<\/span> <\/span>spent<\/span> <\/span>in<\/span> <\/span>the<\/span> <\/span>various<\/span> <\/span>CPU<\/span> <\/span>states<\/span>  94:<\/span>        <\/span> <\/span>*<\/span> <\/span>(<\/span>averaged<\/span> <\/span>over<\/span> <\/span>all<\/span> <\/span>CPUs<\/span>)<\/span>.<\/span> <\/span>If<\/span> <\/span>you<\/span> <\/span>know<\/span> <\/span>the<\/span> <\/span>regular<\/span> <\/span>tick<\/span> <\/span>rate<\/span> <\/span>of<\/span> <\/span>the<\/span> <\/span>target<\/span>  95:<\/span>        <\/span> <\/span>*<\/span> <\/span>system<\/span> <\/span>you<\/span> <\/span>may<\/span> <\/span>calculate<\/span> <\/span>the<\/span> <\/span>number<\/span> <\/span>of<\/span> <\/span>CPUs<\/span> <\/span>from<\/span> <\/span>the<\/span> <\/span>sum<\/span> <\/span>of<\/span> <\/span>C<\/span><<\/span>cpu_time<\/span>><\/span>  96:<\/span>        <\/span> <\/span>*<\/span> <\/span>increments<\/span> <\/span>and<\/span> <\/span>the<\/span> <\/span>time<\/span> <\/span>interval<\/span> <\/span>between<\/span> <\/span>the<\/span> <\/span>samples<\/span>.<\/span> <\/span>Most<\/span> <\/span>often<\/span> <\/span>you<\/span>  97:<\/span>        <\/span> <\/span>*<\/span> <\/span>will<\/span> <\/span>be<\/span> <\/span>interested<\/span> <\/span>in<\/span> <\/span>the<\/span> <\/span>percentage<\/span> <\/span>of<\/span> <\/span>CPU<\/span> <\/span>states<\/span> <\/span>only<\/span>.<\/span>  98:<\/span>        <\/span> <\/span>*\/<\/span>  99:<\/span>        public<\/span> void<\/span> testRstat<\/span>() {<\/span> 100:<\/span>                OncRpcClientAuthUnix authUnix =<\/span> null<\/span>; 101:<\/span>                RstatClient rstat =<\/span> null<\/span>; 102:<\/span>                statstime stats =<\/span> null<\/span>; 103:<\/span>                statstime stats2 =<\/span> null<\/span>; 104:<\/span>                try<\/span> {<\/span> 105:<\/span>                        authUnix =<\/span> new<\/span> OncRpcClientAuthUnix<\/span>( 106:<\/span>                                        System.getProperty<\/span>(\"<\/span>test.rstat.server<\/span>\"<\/span>), 107:<\/span>                                        Integer.parseInt<\/span>(RSTAT_BUNDLE.getString<\/span>(\"<\/span>RstatPing.user.id<\/span>\"<\/span>)), 108:<\/span>                                        Integer.parseInt<\/span>(RSTAT_BUNDLE.getString<\/span>(\"<\/span>RstatPing.user.group<\/span>\"<\/span>)) 109:<\/span>                        ); 110:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Auth<\/span> <\/span>Unix<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, authUnix); 111:<\/span>                  112:<\/span>                        rstat =<\/span> new<\/span> RstatClient<\/span>( 113:<\/span>                                        InetAddress.getByName<\/span>(System.getProperty<\/span>(\"<\/span>test.rstat.server<\/span>\"<\/span>)), 114:<\/span>                                        OncRpcProtocols.ONCRPC_UDP 115:<\/span>                                        ); 116:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Rstat<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, rstat); 117:<\/span>                        rstat.getClient<\/span>().setAuth<\/span>(authUnix); 118:<\/span>                        rstat.getClient<\/span>().setTimeout<\/span>(MAX_TIMEOUT); 119:<\/span>                        stats =<\/span> rstat.RSTATPROC_STATS_3<\/span>(); 120:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>statsswtch<\/span> <\/span>stats<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, stats); 121:<\/span>                  122:<\/span>                        \/\/<\/span> <\/span>Now<\/span> <\/span>wait<\/span> <\/span>a<\/span> <\/span>little<\/span> <\/span>bit<\/span> <\/span>before<\/span> <\/span>taking<\/span> <\/span>the<\/span> <\/span>next<\/span> <\/span>snapshot<\/span> 123:<\/span>                        long<\/span> wait =<\/span> Long.parseLong<\/span>(System.getProperty<\/span>(\"<\/span>test.rstat.wait<\/span>\"<\/span>)); 124:<\/span>                        Thread.sleep<\/span>(wait); 125:<\/span>                  126:<\/span>                        \/\/<\/span> <\/span>Get<\/span> <\/span>another<\/span> <\/span>snapshot<\/span> 127:<\/span>                        stats2 =<\/span> rstat.RSTATPROC_STATS_3<\/span>(); 128:<\/span>                  129:<\/span>                        long<\/span> timeElaps =<\/span>  stats2.getCurtime<\/span>().tv_sec -<\/span>stats.getCurtime<\/span>().tv_sec; 130:<\/span>                  131:<\/span>                        Object [] statColl =<\/span> new<\/span> Object[23<\/span>]; 132:<\/span>                        statColl[0<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.if_collisions -<\/span>stats.if_collisions)\/<\/span> timeElaps); 133:<\/span>                        statColl[1<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.if_ierrors -<\/span>stats.if_ierrors) \/<\/span>timeElaps); 134:<\/span>                        statColl[2<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.if_ipackets -<\/span>stats.if_ipackets) \/<\/span>timeElaps); 135:<\/span>                        statColl[3<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.if_oerrors -<\/span>stats.if_oerrors) \/<\/span>timeElaps); 136:<\/span>                        statColl[4<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.if_opackets -<\/span>stats.if_opackets) \/<\/span>timeElaps); 137:<\/span>                        statColl[5<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.v_intr -<\/span>stats.v_intr) \/<\/span>timeElaps); 138:<\/span>                        statColl[6<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.v_pgpgin -<\/span>stats.v_pgpgin) \/<\/span>timeElaps); 139:<\/span>                        statColl[7<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.v_pgpgout -<\/span>stats.v_pgpgout) \/<\/span>timeElaps); 140:<\/span>                        statColl[8<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.v_pswpin -<\/span>stats.v_pswpin) \/<\/span>timeElaps); 141:<\/span>                        statColl[9<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.v_pswpout -<\/span>stats.v_pswpout) \/<\/span>timeElaps); 142:<\/span>                        statColl[10<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.v_swtch -<\/span>stats.v_swtch) \/<\/span>timeElaps); 143:<\/span>                        statColl[11<\/span>] =<\/span> new<\/span> Double<\/span>(stats2.getAvenrun<\/span>(0<\/span>) \/<\/span> 256<\/span>.0<\/span>); 144:<\/span>                        statColl[12<\/span>] =<\/span> new<\/span> Double<\/span>(stats2.getAvenrun<\/span>(1<\/span>) \/<\/span> 256<\/span>.0<\/span>); 145:<\/span>                        statColl[13<\/span>] =<\/span> new<\/span> Double<\/span>(stats2.getAvenrun<\/span>(2<\/span>) \/<\/span> 256<\/span>.0<\/span>); 146:<\/span>                        statColl[14<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getCp_time<\/span>(0<\/span>) -<\/span>stats.getCp_time<\/span>(0<\/span>))\/<\/span> timeElaps); 147:<\/span>                        statColl[15<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getCp_time<\/span>(1<\/span>) -<\/span>stats.getCp_time<\/span>(1<\/span>)) \/<\/span> timeElaps); 148:<\/span>                        statColl[16<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getCp_time<\/span>(2<\/span>) -<\/span>stats.getCp_time<\/span>(2<\/span>)) \/<\/span> timeElaps); 149:<\/span>                        statColl[17<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getCp_time<\/span>(3<\/span>) -<\/span>stats.getCp_time<\/span>(3<\/span>))\/<\/span> timeElaps); 150:<\/span>                        statColl[18<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getDk_xfer<\/span>(0<\/span>) -<\/span>stats.getDk_xfer<\/span>(0<\/span>))\/<\/span> timeElaps); 151:<\/span>                        statColl[19<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getDk_xfer<\/span>(1<\/span>) -<\/span>stats.getDk_xfer<\/span>(1<\/span>)) \/<\/span> timeElaps); 152:<\/span>                        statColl[20<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getDk_xfer<\/span>(2<\/span>) -<\/span>stats.getDk_xfer<\/span>(2<\/span>)) \/<\/span> timeElaps); 153:<\/span>                        statColl[21<\/span>] =<\/span> new<\/span> Long<\/span>((stats2.getDk_xfer<\/span>(3<\/span>) -<\/span>stats.getDk_xfer<\/span>(3<\/span>)) \/<\/span> timeElaps); 154:<\/span>                        statColl[22<\/span>] =<\/span> new<\/span> Long<\/span>(stats2.getBoottime<\/span>().tv_sec); 155:<\/span>                  156:<\/span>                        StringBuffer info =<\/span> new<\/span> StringBuffer<\/span>(); 157:<\/span>                        info.append<\/span>(\"<\/span>Rstat<\/span> <\/span>unit<\/span> <\/span>test\\n<\/span>\"<\/span>); 158:<\/span>                        info.append<\/span>(\"<\/span>Time<\/span> <\/span>elapsed<\/span> <\/span>between<\/span> <\/span>measures<\/span> <\/span>(seconds):<\/span> <\/span>\"<\/span> +<\/span>timeElaps +<\/span> \"<\/span>\\n<\/span>\"<\/span>); 159:<\/span>                        info.append<\/span>(\"<\/span>if_collisions=%s\\n<\/span>\"<\/span>); 160:<\/span>                        info.append<\/span>(\"<\/span>if_ierrors=%s\\n<\/span>\"<\/span>); 161:<\/span>                        info.append<\/span>(\"<\/span>if_ipackets=%s\\n<\/span>\"<\/span>); 162:<\/span>                        info.append<\/span>(\"<\/span>if_oerrors=%s\\n<\/span>\"<\/span>); 163:<\/span>                        info.append<\/span>(\"<\/span>if_opackets=%s\\n<\/span>\"<\/span>); 164:<\/span>                        info.append<\/span>(\"<\/span>v_intr=%s\\n<\/span>\"<\/span>); 165:<\/span>                        info.append<\/span>(\"<\/span>v_pgpgin=%s\\n<\/span>\"<\/span>); 166:<\/span>                        info.append<\/span>(\"<\/span>v_pgpgout=%s\\n<\/span>\"<\/span>); 167:<\/span>                        info.append<\/span>(\"<\/span>v_pswpin=%s\\n<\/span>\"<\/span>); 168:<\/span>                        info.append<\/span>(\"<\/span>v_pswpout=%s\\n<\/span>\"<\/span>); 169:<\/span>                        info.append<\/span>(\"<\/span>v_swtch=%s\\n<\/span>\"<\/span>); 170:<\/span>                        info.append<\/span>(\"<\/span>Avenrun<\/span> <\/span>(CPU<\/span> <\/span>load)<\/span> <\/span>0=%s\\n<\/span>\"<\/span>); 171:<\/span>                        info.append<\/span>(\"<\/span>Avenrun<\/span> <\/span>(CPU<\/span> <\/span>load)<\/span> <\/span>1=%s\\n<\/span>\"<\/span>); 172:<\/span>                        info.append<\/span>(\"<\/span>Avenrun<\/span> <\/span>(CPU<\/span> <\/span>load)<\/span> <\/span>2=%s\\n<\/span>\"<\/span>); 173:<\/span>                        info.append<\/span>(\"<\/span>CP_time<\/span> <\/span>0<\/span> <\/span>Usr=%s\\n<\/span>\"<\/span>); 174:<\/span>                        info.append<\/span>(\"<\/span>CP_time<\/span> <\/span>1<\/span> <\/span>System=%s\\n<\/span>\"<\/span>); 175:<\/span>                        info.append<\/span>(\"<\/span>CP_time<\/span> <\/span>2<\/span> <\/span>Wio=%s\\n<\/span>\"<\/span>); 176:<\/span>                        info.append<\/span>(\"<\/span>CP_time<\/span> <\/span>3<\/span> <\/span>Idle=%s\\n<\/span>\"<\/span>); 177:<\/span>                        info.append<\/span>(\"<\/span>Dk_xfer<\/span> <\/span>0=%s\\n<\/span>\"<\/span>); 178:<\/span>                        info.append<\/span>(\"<\/span>Dk_xfer<\/span> <\/span>1=%s\\n<\/span>\"<\/span>); 179:<\/span>                        info.append<\/span>(\"<\/span>Dk_xfer<\/span> <\/span>2=%s\\n<\/span>\"<\/span>); 180:<\/span>                        info.append<\/span>(\"<\/span>Dk_xfer<\/span> <\/span>3=%s\\n<\/span>\"<\/span>); 181:<\/span>                        info.append<\/span>(\"<\/span>Raw<\/span> <\/span>uptime<\/span> <\/span>in<\/span> <\/span>seconds=%s\\n<\/span>\"<\/span>); 182:<\/span>                  183:<\/span>                        \/\/<\/span> <\/span>Spit<\/span> <\/span>the<\/span> <\/span>results<\/span> <\/span>out<\/span> 184:<\/span>                        System.out.printf<\/span>( 185:<\/span>                                        info.toString<\/span>(), 186:<\/span>                                        statColl 187:<\/span>                                        ); 188:<\/span>                }<\/span> catch<\/span> (Throwable throwbl) {<\/span> \r\n189:<\/span>                        Assert.fail<\/span>(\"<\/span>Got<\/span> <\/span>an<\/span> <\/span>exception:<\/span> <\/span>\"<\/span> +<\/span> throwbl.toString<\/span>()); \r\n190:<\/span>                        throwbl.printStackTrace<\/span>(); \r\n191:<\/span>                }<\/span> finally<\/span> {<\/span> 1\r\n92:<\/span>                        \/\/<\/span> <\/span>Empty<\/span> <\/span>for<\/span> <\/span>now<\/span> \r\n193:<\/span>                }<\/span> \r\n194:<\/span>        }<\/span> \r\n195:<\/span>}<\/span><\/pre>\n
    El resultado de las pruebas de unidad es el siguiente:<\/p>\n
    \n
    Make sure all the services are running with '\/usr\/sbin\/rpcinfo -p'Exported filesystem: \/usr\/local\/srcMake sure all the services are running with'\/usr\/sbin\/rpcinfo -p'Rstat unit testTime elapsed between measures (seconds): 37if_collisions=0if_ierrors=0if_ipackets=4if_oerrors=0if_opackets=4v_intr=1015v_pgpgin=0v_pgpgout=0v_pswpin=0v_pswpout=0v_swtch=775Avenrun (CPU load) 0=1.4296875Avenrun (CPU load) 1=0.94921875Avenrun (CPU load) 2=0.6875CP_time 0 Usr=29CP_time 1 System=0CP_time 2 Wio=2CP_time 3 Idle=61Dk_xfer 0=0Dk_xfer 1=0Dk_xfer 2=0Dk_xfer 3=0Raw uptime in seconds=1150929416<\/pre>\n<\/blockquote>\n
    El siguiente paso es probar como enviar informaci\u00f3n usando el protocolo de Jabber, pero eso se los mostrar\u00e9 en un siguiente articulo \ud83d\ude09<\/p>\n
    El sistema no es de grado comercial; Uno de verdad deber\u00eda estar en capacidad de monitorear varios servidores a la vez, y si debe escalar entonces quizas usar Jabber como presentaci\u00f3n quizas no sea lo adecuado. Pero nadie niega que fu\u00e9 divertido \ud83d\ude09<\/p>\n
    Referencias:<\/p>\n