ActiveMQ 和JAXWS整合

??? 在多个系统中可能考虑到远程访问等的，采用WebService方式和远程系统的JMS消息系统交互。本文采用ActiveMQ和JAXWS实现。客户端通过webservice将消息发送给服务端的消息队列。

package easyway.app.activemq.ws;import javax.jws.WebMethod;import javax.jws.WebParam;import javax.jws.WebService;/** * 服务端接口 * @author longgangbai * */@WebServicepublic interface HelloWorld {/** * 启动相关的服务方法 * @param name * @return */    @WebMethod    String sayHi(@WebParam(name = "name") String name);}

?

?

?

?

package easyway.app.activemq.ws;import javax.jws.WebService;/** * 服务端实现 * @author longgangbai * */@WebServicepublic class HelloWorldImpl implements HelloWorld {    /*     * (non-Javadoc)     * @see test.IHello#sayHi(java.lang.String)     */    public String sayHi(String name) {        return "Hello " + name;    }}

?

?

?

服务端通过WebService发布JMS消息的信息：

package easyway.app.activemq.ws.server;import javax.xml.ws.Endpoint;import org.apache.activemq.ActiveMQConnectionFactory;import org.apache.activemq.broker.BrokerService;import easyway.app.activemq.ws.HelloWorldImpl;/** * 通过WebService提供本地的JMS服务 * @author longgangbai * */public class ActiveMQWServer {    //设置JMS的URI的格式：jms:queue or topic:destinationprivate static final String JMS_ENDPOINT_URI = "jms:queue:jaxws.jmstransport.queue?timeToLive=1000"+ "&jndiConnectionFactoryName=ConnectionFactory"+ "&jndiInitialContextFactory"+ "=org.apache.activemq.jndi.ActiveMQInitialContextFactory";private ActiveMQWServer() {}public static void main(String args[]) throws Exception {ActiveMQWServer  server=new ActiveMQWServer();//初始化Broker的方法server.initBrokerService();//启动JAXWS相关的 服务server.launchJaxwsApi();System.out.println("Server ready... Press any key to exit");System.in.read();System.out.println("Server exiting");System.exit(0);}/** * 启动ActiveMQ的Broker * @throws Exception */public void initBrokerService() throws Exception{BrokerService  brokerService=new BrokerService();brokerService.addConnector( ActiveMQConnectionFactory.DEFAULT_BROKER_BIND_URL);brokerService.setDataDirectory("target/activemq-data");brokerService.start();}    /**     * 发布WebService服务     *     */private  void launchJaxwsApi() {Endpoint.publish(JMS_ENDPOINT_URI, new HelloWorldImpl());}}

?

?

?

客户端通过webservice发送消息到服务端的消息队列：

package easyway.app.activemq.ws.client;import javax.xml.namespace.QName;import javax.xml.ws.Service;import org.apache.cxf.transport.jms.spec.JMSSpecConstants;import easyway.app.activemq.ws.HelloWorld;/** * 客户端通过WebService向服务端队列中发送消息 * @author longgangbai * */public final class ActiveMQWSClient {//WebService请求的url的路径private static final String JMS_ENDPOINT_URI = "jms:queue:jaxws.jmstransport.queue?timeToLive=1000"+ "&jndiConnectionFactoryName=ConnectionFactory"+ "&jndiInitialContextFactory"+ "=org.apache.activemq.jndi.ActiveMQInitialContextFactory";    private static final QName SERVICE_QNAME =        new QName("http://ws.activemq.app.easyway/", "HelloWorldImplService");    private static final QName PORT_QNAME =        new QName("http://ws.activemq.app.easyway/", "HelloWorldPort");    private ActiveMQWSClient() {    }    /**     * 客户端调用WS服务     * @return     */    private static HelloWorld createClientJaxWs() {    //创建相关的 服务        Service service = Service.create(SERVICE_QNAME);        // Add a port to the Service        service.addPort(PORT_QNAME, JMSSpecConstants.SOAP_JMS_SPECIFICATION_TRANSPORTID, JMS_ENDPOINT_URI);        return service.getPort(HelloWorld.class);    }        public static void main(String[] args) throws Exception {            HelloWorld client = createClientJaxWs();        String reply = client.sayHi("HI");        System.out.println(reply);    }}

?