spring 教程

spring和jms集成 -888棋牌游戏

要将spring与jms集成，您需要创建两个应用程序。

jms接收器应用程序 jms sender应用程序

要使用spring创建jms应用程序，我们使用apache的 active mq server 创建队列。

让我们看看集成spring应用程序的简单步骤。使用jms:

必需的jar文件

1、您需要添加 spring core ， spring misc ， spring aop ， spring j2ee 和 spring持久性内核 jar文件。

下载spring的所有jar文件，包括aop，mvc，j2ee，remoting，oxm等。

2、添加 activemqall5。 9.jar 文件位于activemq目录中。

在activemq server中创建队列

下载active mq服务器下载active mq

双击 activemq。 bat 文件位于apache-activemq-5.9.1-bin \ apache-activemq-5.9.1 \ bin \ win64或win32目录中。

现在将打开activemq服务器控制台。

通过 http://localhost:8161/admin/网址访问activemq服务器的管理控制台。

打开activemq服务器

现在，单击 队列链接，在文本字段中写入 myqueue ，然后单击创建按钮

在activemq服务器中创建队列

jms接收器应用程序

让我们看一下将spring应用程序与jms集成的简单步骤:

mymessagelistener.java testlistener.java applicationcontext.xml

1)mymessagelistener.java 

package com.nhooo;
import javax.jms.message;
import javax.jms.messagelistener;
import javax.jms.textmessage;
public class mymessagelistener implements messagelistener{
    @override
    public void onmessage(message m) {
        textmessage message=(textmessage)m;
        try{
            system.out.println(message.gettext());
        }catch (exception e) {e.printstacktrace();   }
    }
}

2)testlistener.java 

package com.nhooo;
import org.springframework.context.support.genericxmlapplicationcontext;
public class testlistener {
public static void main(string[] args) {
    genericxmlapplicationcontext ctx=new genericxmlapplicationcontext();
    ctx.load("classpath:applicationcontext.xml");
    ctx.refresh();
    
    while(true){}
}
}

3)applicationcontext.xml

jms sender应用程序

让我们看一下创建jms sender应用程序的文件:

mymessagesender.java testjmssender.java applicationcontext.xml

1)mymessagelistener.java 

package com.nhooo;
import javax.jms.*;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.jms.core.jmstemplate;
import org.springframework.jms.core.messagecreator;
import org.springframework.stereotype.component;
@component("messagesender")
public class mymessagesender {
@autowired
private jmstemplate jmstemplate;
public void sendmessage(final string message){
    jmstemplate.send(new messagecreator(){
        @override
        public message createmessage(session session) throws jmsexception {
            return session.createtextmessage(message);
        }
    });
}
}

2)testjmssender.java 

package com.nhooo;
import org.springframework.context.support.genericxmlapplicationcontext;
public class testjmssender {
public static void main(string[] args) {
    genericxmlapplicationcontext ctx=new genericxmlapplicationcontext();
    ctx.load("classpath:applicationcontext.xml");
    ctx.refresh();
    
    mymessagesender sender=ctx.getbean("messagesender",mymessagesender.class);
    sender.sendmessage("hello jms3");
    
}
}

3)applicationcontext.xml
spring streamspring远程处理(通过burlap示例)

888棋牌游戏的友情链接：

网站地图