使用Vysper，TomEE和PrimeFaces将XMPP服务器嵌入JSFWeb应用程序内部

我有一个需要在完成某些工作时通知用户的应用程序。 它使用JSF和Primefaces&＃xff0c;因此可以使用大气 &＃xff08;也称为Push&＃xff09;来实现这种通知。

但是另一个有趣的方法是使用嵌入在Java Web应用程序中的XMPP服务器。 好的&＃xff0c;好的&＃xff0c;您不必嵌入它&＃xff0c;只需运行一个工业级XMPP服务器的实例&＃xff0c;例如Openfire和Tigase即可 。 但是&＃xff0c;嘿&＃xff0c;我们只是在玩些游戏&＃xff0c;所以我将向您展示如何使用Vysper进行操作&＃xff0c; Vysper是使用Apache Mina开发的概念验证游戏 &＃xff0c;只需几分钟即可轻松完成。

在展示如何做之前&＃xff0c;很高兴记住线程和JEE应用程序通常不会混合使用 &＃xff0c;因此我们可以玩&＃xff0c;但是我们必须知道我们在做什么。

首先&＃xff0c;您将需要这些JAR&＃xff0c;其中大多数来自Vysper。 只是几个&＃xff1f;

• aopalliance-1.0.jar
• commons-codec-1.4.jar
• commons-collections-3.1.jar
• commons-io-1.4.jar
• commons-lang-2.5.jar
• commons-logging-1.1.jar
• 并发1.3.4.jar
• derby-10.2.1.6.jar
• dnsjava-2.0.8.jar
• ehcache-core-2.2.0.jar
• fontbox-0.1.0.jar
• jackrabbit-api-1.5.0.jar
• jackrabbit-core-1.5.3.jar
• jackrabbit-jcr-commons-1.5.3.jar
• jackrabbit-spi-1.5.0.jar
• jackrabbit-spi-commons-1.5.0.jar
• jackrabbit-text-extractors-1.5.0.jar
• jcl-over-slf4j-1.5.3.jar
• jcr-1.0.jar
• jempbox-0.2.0.jar
• jetty-continuation-7.2.1.v20101111.jar
• jetty-http-7.2.1.v20101111.jar
• jetty-io-7.2.1.v20101111.jar
• jetty-security-7.2.1.v20101111.jar
• jetty-server-7.2.1.v20101111.jar
• jetty-servlet-7.2.1.v20101111.jar
• jetty-util-7.2.1.v20101111.jar
• jetty-websocket-7.2.1.v20101111.jar
• log4j-1.2.14.jar
• lucene-core-2.3.2.jar
• mina-core-2.0.2.jar
• nbxml-0.7.jar
• nekohtml-1.9.7.jar
• pdfbox-0.7.3.jar
• poi-3.0.2-FINAL.jar
• poi-scratchpad-3.0.2-FINAL.jar
• primefaces-4.0.jar
• servlet-api-2.5.jar
• slf4j-api-1.5.3.jar
• slf4j-log4j12-1.5.3.jar
• smack-3.1.0.jar
• smackx-3.1.0.jar
• spec-compliance-0.7.jar
• 弹簧-aop-3.0.5.RELEASE.jar
• 弹簧-asm-3.0.5.RELEASE.jar
• Spring Bean3.0.5.RELEASE.jar
• spring-context-3.0.5.RELEASE.jar
• 弹簧核心-3.0.5.RELEASE.jar
• spring-expression-3.0.5.RELEASE.jar
• vysper-core-0.7.jar
• vysper-websockets-0.7.jar
• xep0045-muc-0.7.jar
• xep0060-pubsub-0.7.jar
• xep0124-xep0206-bosh-0.7.jar
• xercesImpl-2.8.1.jar
• xml-apis-1.3.03.jar

现在&＃xff0c;从Vysper复制虚假证书&＃xff0c;以便您的XMPP服务器可以在“安全”通道下“工作”。 它称为bogus_mina_tls.cert。

我的xhtml看起来像这样&＃xff1a;

很简单吧&＃xff1f; 托管Bean也很容易。

import java.io.Serializable;import javax.annotation.PostConstruct;
import javax.ejb.EJB;
import javax.faces.bean.ManagedBean;
import javax.faces.bean.ViewScoped;import org.jivesoftware.smack.XMPPException;&＃64;ManagedBean
&＃64;ViewScoped
public class MessagingMB implements Serializable {private static final long serialVersionUID &＃61; -9092497421080796430L;&＃64;EJBprivate JSFUtilEJB jsfUtilEJB;&＃64;PostConstructpublic void init() {}public void sendMessage() {try {new BasicClient().test();} catch (XMPPException e) {jsfUtilEJB.addErrorMessage(e,"Could not send");}}
}

当然&＃xff0c;EJB&＃xff1a;

import javax.ejb.Stateless;
import javax.faces.application.FacesMessage;
import javax.faces.application.FacesMessage.Severity;
import javax.faces.context.FacesContext;&＃64;Stateless
public class JSFUtilEJB {&＃64;SuppressWarnings("unchecked")public T findBean(String beanName) {FacesContext context &＃61; FacesContext.getCurrentInstance();return (T) context.getApplication().evaluateExpressionGet(context, "#{" &＃43; beanName &＃43; "}", Object.class);}public long addErrorMessage(String msg) {return addMessage(null,FacesMessage.SEVERITY_ERROR,msg);}public long addErrorMessage(Exception e,String summary){return addMessage(e,FacesMessage.SEVERITY_ERROR,summary);}public long addFatalErrorMessage(Exception e,String summary){return addMessage(e,FacesMessage.SEVERITY_FATAL,summary);}public long addInfoMessage(String summary){return addMessage(null,FacesMessage.SEVERITY_INFO,summary);}public long addWarnMessage(Exception e,String summary){return addMessage(e,FacesMessage.SEVERITY_WARN,summary);}public long addErrorMessage(Exception e) {return addMessage(e,FacesMessage.SEVERITY_ERROR,e.getMessage(),e.getClass().getSimpleName());}private long addMessage(Exception e,Severity severity, String summary) {FacesContext context &＃61; FacesContext.getCurrentInstance();String clientId &＃61; null;long id &＃61; -1;if (e !&＃61; null){id &＃61; printStackTrace(e);FacesMessage facesMessage &＃61; null;if (e.getCause() instanceof org.apache.openjpa.persistence.EntityExistsException){facesMessage &＃61; new FacesMessage(severity,"[Error: #"&＃43;id&＃43;"] "&＃43;summary,"You are trying are to add a new object that already exists or your&＃39;re trying to violate a unique constraint)" ); }else{facesMessage &＃61; new FacesMessage(severity,"[Error: #"&＃43;id&＃43;"] "&＃43;summary,e.getMessage() );}context.addMessage(clientId , facesMessage );}else{FacesMessage facesMessage &＃61; new FacesMessage(severity,summary," ");context.addMessage(clientId , facesMessage );}return id;}private long addMessage(Exception e,Severity severity, String summary, String detail) {FacesContext context &＃61; FacesContext.getCurrentInstance();String clientId &＃61; null;long id &＃61; -1;if (e !&＃61; null){id &＃61; printStackTrace(e); FacesMessage facesMessage &＃61; new FacesMessage(severity,"["&＃43;id&＃43;"] "&＃43;summary,detail );context.addMessage(clientId , facesMessage );}else{FacesMessage facesMessage &＃61; new FacesMessage(severity,summary,detail );context.addMessage(clientId , facesMessage );}return id;}public long printStackTrace(Exception e){long uniqueId &＃61; System.currentTimeMillis();return uniqueId;}}

和

import java.io.File;
import java.io.Serializable;import javax.annotation.PostConstruct;
import javax.ejb.Singleton;
import javax.ejb.Startup;import org.apache.vysper.mina.TCPEndpoint;
import org.apache.vysper.storage.StorageProviderRegistry;
import org.apache.vysper.storage.inmemory.MemoryStorageProviderRegistry;
import org.apache.vysper.xmpp.addressing.EntityImpl;
import org.apache.vysper.xmpp.authorization.AccountManagement;
import org.apache.vysper.xmpp.server.XMPPServer;&＃64;Startup
&＃64;Singleton
public class XmppEJB implements Serializable {/***
06/09/2014*/private static final long serialVersionUID &＃61; 1L;private boolean started;&＃64;PostConstructpublic void init() {try {// choose the storage you want to use// StorageProviderRegistry providerRegistry &＃61; new JcrStorageProviderRegistry();StorageProviderRegistry providerRegistry &＃61; new MemoryStorageProviderRegistry();final AccountManagement accountManagement &＃61; (AccountManagement) providerRegistry.retrieve(AccountManagement.class);if(!accountManagement.verifyAccountExists(EntityImpl.parse("user1&＃64;vysper.org"))) {accountManagement.addUser(EntityImpl.parse("user1&＃64;vysper.org"), "password");}if(!accountManagement.verifyAccountExists(EntityImpl.parse("user2&＃64;vysper.org"))) {accountManagement.addUser(EntityImpl.parse("user2&＃64;vysper.org"), "password");}XMPPServer server &＃61; new XMPPServer("vysper.org");server.addEndpoint(new TCPEndpoint());server.setStorageProviderRegistry(providerRegistry);server.setTLSCertificateInfo(new File("/path/to/bogus_mina_tls.cert"), "boguspw");server.start();System.out.println("server is running...");} catch (Exception e) {e.printStackTrace();}started &＃61; true;}public boolean isStarted() {return this.started;}}

和基本客户&＃xff0c; 来自Vysper 。

import java.util.Date;import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.PacketListener;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.SASLAuthentication;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.filter.PacketFilter;
import org.jivesoftware.smack.packet.IQ;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.packet.Packet;
import org.jivesoftware.smack.packet.PacketExtension;
import org.jivesoftware.smack.packet.Presence;
import org.jivesoftware.smackx.packet.Time;
import org.jivesoftware.smackx.packet.Version;public class BasicClient {static class IQListener implements PacketListener {public void processPacket(Packet packet) {IQ iq &＃61; (IQ) packet;String iqString &＃61; iq.toString();System.out.println("T" &＃43; System.currentTimeMillis() &＃43; " IQ: "&＃43; iqString &＃43; ": " &＃43; iq.toXML());}}static class PresenceListener implements PacketListener {public void processPacket(Packet packet) {Presence presence &＃61; (Presence) packet;String iqString &＃61; presence.toString();final PacketExtension extension &＃61; presence.getExtension("http://jabber.org/protocol/caps");if (extension !&＃61; null)System.out.println("T" &＃43; System.currentTimeMillis() &＃43; " Pres: "&＃43; iqString &＃43; ": " &＃43; presence.toXML());}}public void test() throws XMPPException {String me &＃61; "user2&＃64;vysper.org";String to &＃61; "user1&＃64;vysper.org";try {ConnectionConfiguration connectionConfiguration &＃61; new ConnectionConfiguration("localhost");connectionConfiguration.setCompressionEnabled(false);connectionConfiguration.setSelfSignedCertificateEnabled(true);connectionConfiguration.setExpiredCertificatesCheckEnabled(false);
// connectionConfiguration.setDebuggerEnabled(true);connectionConfiguration.setSecurityMode(ConnectionConfiguration.SecurityMode.required);
// XMPPConnection.DEBUG_ENABLED &＃61; true;XMPPConnection connection &＃61; new XMPPConnection(connectionConfiguration);connection.connect();SASLAuthentication saslAuthentication &＃61; connection.getSASLAuthentication();saslAuthentication.authenticate(me, "password", "test");connection.login(me, "pqssword");connection.getRoster().setSubscriptionMode(Roster.SubscriptionMode.accept_all);connection.addPacketListener(new IQListener(), new PacketFilter() {public boolean accept(Packet packet) {return packet instanceof IQ;}});connection.addPacketListener(new PresenceListener(),new PacketFilter() {public boolean accept(Packet packet) {return packet instanceof Presence;}});Chat chat &＃61; null;if (to !&＃61; null) {Presence presence &＃61; new Presence(Presence.Type.subscribe);presence.setFrom(connection.getUser());String toEntity &＃61; to;presence.setTo(toEntity);connection.sendPacket(presence);chat &＃61; connection.getChatManager().createChat(toEntity,new MessageListener() {public void processMessage(Chat inchat,Message message) {System.out.println("log received message: "&＃43; message.getBody());}});}connection.sendPacket(new Presence(Presence.Type.available,"pommes", 1, Presence.Mode.available));Thread.sleep(1000);// query server versionsendIQGetWithTimestamp(connection, new Version());// query server timesendIQGetWithTimestamp(connection, new Time());chat.sendMessage("Hello " &＃43; to &＃43; " at " &＃43; new Date());connection.disconnect();} catch (Throwable e) {e.printStackTrace(); // To change body of catch statement use File |// Settings | File Templates.}System.out.println("bye");}private static void sendIQGetWithTimestamp(XMPPConnection connection, IQ iq) {iq.setType(IQ.Type.GET);connection.sendPacket(iq);System.out.println("T" &＃43; System.currentTimeMillis()&＃43; " IQ request sent");}
}

我们快要准备好了。 当然&＃xff0c;现在我们需要一个XMPP客户端&＃xff0c;例如Pidgin 。

首先&＃xff0c;让我对这个博客表示感谢 &＃xff0c;因为我不知道为什么&＃xff0c;Vysper站点几乎没有关于如何配置Pidgin的信息&＃xff0c;因此这篇博客非常有用。

让我向您展示我的pidgin用户的样子&＃xff1a;

我知道&＃xff0c;是葡萄牙语。

就是这样。 我们都准备好了。 启动您的JSF Web应用程序并播放。

请注意&＃xff0c;通信是双向的&＃xff0c;因此您可以仅使用XMPP客户端将命令发送到服务器。 为此&＃xff0c;您只需要更改此侦听器即可&＃xff1a;

chat &＃61; connection.getChatManager().createChat(toEntity,new MessageListener() {public void processMessage(Chat inchat,Message message) {System.out.println("log received message: "&＃43; message.getBody());}});

我想知道我们是否可以创建一个DSL来处理一些命令&＃xff0c;是否可以找到一些自动完成的pidgin插件来使用该DSL编写命令。 欢迎提出建议&＃xff01;

ps。 EJB不能正常关闭服务器。 但是我敢打赌&＃xff0c;如果服务器关闭&＃xff0c;有一些EJB注释可以做到这一点。

翻译自: https://www.javacodegeeks.com/2014/09/embedding-a-xmpp-server-inside-your-jsf-web-application-using-vysper-tomee-and-primefaces.html