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

\"java
\nEl taxista se encarg\u00f3 de decirle a su novia, y esta reg\u00f3 el cuento por all\u00ed…<\/a><\/p>\n

En una primera parte<\/a> les comentaba como hablar con NFS y a Rstatd desde Java usando RPC. Ahora vamos a terminar la aplicaci\u00f3n enviando mensajes usando Jabber.<\/p>\n

El protocolo de Jabber es muy completo. Sin embargo con esas caracter\u00edsticas viene la complejidad, as\u00ed que decid\u00ed tomar un atajo y en vez de complicarme la vida viendo como trabaja el protocolo me decid\u00ed a usar las libreria Smack<\/a> (JiveSoftware, OpenSource). Como este articulo no se trata de como instalar un servidor de Jabber<\/a> entonces vamos a utilizar una cuenta de Google Talk<\/a> la cual habla el protocolo abierto XMPP<\/a> .<\/p>\n

No me gusta guardar ni usuarios ni passwords en el c\u00f3digo, y mucho menos si el c\u00f3digo va a estar en Internet :), as\u00ed que modificamos un poco el archivo build.xml para leer un nuevo archivo de propiedades el cual tendr\u00e1 los parametros requeridos para esta prueba.<\/p>\n

Bueno, y el c\u00f3digo super sencillo para probar la parte de la mensajer\u00eda:<\/p>\n


\n–><\/p>\n

 <\/p>\n

1:<\/span>package<\/span> com.kodegeek.blog.monitoring.rpc;   \r\n2:<\/span>   \r\n3:<\/span>import<\/span> org.jivesoftware.smack.Chat;   \r\n4:<\/span>import<\/span> org.jivesoftware.smack.XMPPConnection;   \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>  \r\n10:<\/span>public<\/span> class<\/span> TestJabber extends<\/span> TestCase {<\/span>  \r\n11:<\/span>     \r\n12:<\/span>     \r\n13:<\/span>        protected<\/span> void<\/span> setUp<\/span>() throws<\/span> Exception {<\/span>  \r\n14:<\/span>                super<\/span>.setUp<\/span>();  \r\n15:<\/span>        }<\/span>  \r\n16:<\/span>  \r\n17:<\/span>        \/**<\/span>  \r\n18:<\/span>        <\/span> <\/span>*<\/span> <\/span>Test<\/span> <\/span>the<\/span> <\/span>basic<\/span> <\/span>functionality<\/span> <\/span>of<\/span> <\/span>the<\/span> <\/span>Smack<\/span> <\/span>API<\/span>  \r\n19:<\/span>        <\/span> <\/span>*\/<\/span>  \r\n20:<\/span>        public<\/span> void<\/span> testJabber<\/span>() {<\/span>  \r\n21:<\/span>                XMPPConnection conn =<\/span> null<\/span>;  \r\n22:<\/span>                Chat chat =<\/span> null<\/span>;  \r\n23:<\/span>             \r\n24:<\/span>                try<\/span> {<\/span>  \r\n25:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Please<\/span> <\/span>setup<\/span> <\/span>the<\/span> <\/span>address<\/span> <\/span>for<\/span> <\/span>the<\/span> <\/span>Google<\/span> <\/span>talk<\/span> <\/span>server<\/span>\"<\/span>,System.getProperty<\/span>(\"<\/span>jabber.talk.server<\/span>\"<\/span>));  \r\n26:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Please<\/span> <\/span>setup<\/span> <\/span>the<\/span> <\/span>receiving<\/span> <\/span>user<\/span> <\/span>for<\/span> <\/span>the<\/span> <\/span>Google<\/span> <\/span>talk<\/span> <\/span>server<\/span>\"<\/span>,System.getProperty<\/span>(\"<\/span>jabber.talk.port<\/span>\"<\/span>));  \r\n27:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Please<\/span> <\/span>setup<\/span> <\/span>the<\/span> <\/span>send<\/span> <\/span>address<\/span> <\/span>for<\/span> <\/span>the<\/span> <\/span>Google<\/span> <\/span>talk<\/span> <\/span>server<\/span>\"<\/span>,System.getProperty<\/span>(\"<\/span>jabber.talk.send.user<\/span>\"<\/span>)); \r\n28:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Please<\/span> <\/span>setup<\/span> <\/span>the<\/span> <\/span>send<\/span> <\/span>password<\/span> <\/span>for<\/span> <\/span>the<\/span> <\/span>Google<\/span> <\/span>talk<\/span> <\/span>server<\/span>\"<\/span>,System.getProperty<\/span>(\"<\/span>jabber.talk.send.password<\/span>\"<\/span>));  \r\n29:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Please<\/span> <\/span>setup<\/span> <\/span>the<\/span> <\/span>receiving<\/span> <\/span>user<\/span> <\/span>for<\/span> <\/span>the<\/span> <\/span>Google<\/span> <\/span>talk<\/span> <\/span>server<\/span>\"<\/span>,System.getProperty<\/span>(\"<\/span>jabber.talk.rec.user<\/span>\"<\/span>));  \r\n30:<\/span>                     \r\n31:<\/span>                        conn =<\/span>  \r\n32:<\/span>                                new<\/span> XMPPConnection<\/span>(  \r\n33:<\/span>                                System.getProperty<\/span>(\"<\/span>jabber.talk.server<\/span>\"<\/span>),  \r\n34:<\/span>                                Integer.parseInt<\/span>(System.getProperty<\/span>(\"<\/span>jabber.talk.port<\/span>\"<\/span>)));  \r\n35:<\/span>                     \r\n36:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>XMPPConnection<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, conn);  \r\n37:<\/span>                        Assert.assertTrue<\/span>(\"<\/span>We<\/span> <\/span>could<\/span> <\/span>not<\/span> <\/span>connect<\/span> <\/span>to<\/span> <\/span>the<\/span> <\/span>server<\/span>\"<\/span>, conn.isConnected<\/span>());  \r\n38:<\/span>                     \r\n39:<\/span>                        conn.login<\/span>(  \r\n40:<\/span>                               System.getProperty<\/span>(\"<\/span>jabber.talk.send.user<\/span>\"<\/span>),  \r\n41:<\/span>                               System.getProperty<\/span>(\"<\/span>jabber.talk.send.password<\/span>\"<\/span>));  \r\n42:<\/span>                        Assert.assertTrue<\/span>(\"<\/span>Could<\/span> <\/span>not<\/span> <\/span>authenticate<\/span>\"<\/span>,conn.isAuthenticated<\/span>());  \r\n43:<\/span>                     \r\n44:<\/span>                        chat =<\/span> conn.createChat<\/span>(System.getProperty<\/span>(\"<\/span>jabber.talk.rec.user<\/span>\"<\/span>));  \r\n45:<\/span>                        Assert.assertNotNull<\/span>(\"<\/span>Jabber<\/span> <\/span>Chat<\/span> <\/span>is<\/span> <\/span>null<\/span>\"<\/span>, chat);  \r\n46:<\/span>                     \r\n47:<\/span>                        \/**<\/span>  \r\n48:<\/span>        <\/span>        <\/span>        <\/span> <\/span>*<\/span> <\/span>This<\/span> <\/span>is<\/span> <\/span>VERY<\/span> <\/span>important<\/span>.<\/span> <\/span>If<\/span> <\/span>you<\/span> <\/span>don<\/span> <\/span>wait<\/span> <\/span>a<\/span> <\/span>little<\/span> <\/span>bit<\/span> <\/span>then<\/span> <\/span>the<\/span> <\/span>message<\/span> <\/span>will<\/span> <\/span>not<\/span>  \r\n49:<\/span>        <\/span>        <\/span>        <\/span> <\/span>*<\/span> <\/span>be<\/span> <\/span>sent<\/span>.<\/span>  \r\n50:<\/span>        <\/span>        <\/span>        <\/span> <\/span>*\/<\/span>  \r\n51:<\/span>                        Thread.sleep<\/span>(500<\/span>);  \r\n52:<\/span>                        chat.sendMessage<\/span>(\"<\/span>Hey,<\/span> <\/span>this<\/span> <\/span>is<\/span> <\/span>a<\/span> <\/span>message<\/span> <\/span>from<\/span> <\/span>http:\/\/KodeGeek.com<\/span>\"<\/span>);  \r\n53:<\/span>  \r\n54:<\/span>                }<\/span> catch<\/span> (Throwable throwbl) {<\/span>  \r\n55:<\/span>                        Assert.fail<\/span>(\"<\/span>Got<\/span> <\/span>an<\/span> <\/span>exception:<\/span> <\/span>\"<\/span> +<\/span> throwbl.toString<\/span>());  \r\n56:<\/span>                        throwbl.printStackTrace<\/span>();  \r\n57:<\/span>                }<\/span> finally<\/span> {<\/span>  \r\n58:<\/span>                        if<\/span> (conn !<\/span>=<\/span> null<\/span>) {<\/span>  \r\n59:<\/span>                                conn.close<\/span>();  \r\n60:<\/span>                        }<\/span>  \r\n61:<\/span>                }<\/span>  \r\n62:<\/span>        }<\/span>  \r\n63:<\/span>}<\/span><\/pre>\n
Aqui pueden ver como trabaja, una foto vale m\u00e1s que mil palabras:<\/p>\n
\"jabbertest\"
\nMandando mensajes a Jabber desde JUnit. En este caso una cuenta est\u00e1 en Jabber.org y la otra en talk.google.com<\/a><\/p>\n
Si revizan el c\u00f3digo fuente ver\u00e1n que tuve que poner un peque\u00f1o hack<\/a>. Sin embargo no es un gran problema y la librer\u00eda hace lo que promete.<\/p>\n
Como siempre el c\u00f3digo fuente y los binarios est\u00e1n disponibles para que jueguen con ellos. Espero esto les de algunas ideas de como monitorear sus servidores. En una \u00faltima entrega les mostrar\u00e9 como poner todo junto.<\/p>\n
Buscar en Technorati: venezuela<\/a>, java<\/a>, linux<\/a>, Open Source<\/a>, rpc<\/a>, jabber<\/a>
\nBuscar en Blogalaxia: venezuela<\/a>, java<\/a>, linux<\/a>, Open Source<\/a>, rpc<\/a>, jabber<\/a><\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
El taxista se encarg\u00f3 de decirle a su novia, y esta reg\u00f3 el cuento por all\u00ed… En una primera parte les comentaba como hablar con NFS y a Rstatd desde Java usando RPC. Ahora vamos a terminar la aplicaci\u00f3n enviando mensajes usando Jabber. El protocolo de Jabber es muy completo. Sin embargo con esas caracter\u00edsticas […]<\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[9],"tags":[],"_links":{"self":[{"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/posts\/1072"}],"collection":[{"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/comments?post=1072"}],"version-history":[{"count":3,"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/posts\/1072\/revisions"}],"predecessor-version":[{"id":2783,"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/posts\/1072\/revisions\/2783"}],"wp:attachment":[{"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/media?parent=1072"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/categories?post=1072"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/kodegeek.com\/blog\/wp-json\/wp\/v2\/tags?post=1072"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}