spring,weblogic配置jms
1 weblogic的设置都在附件里面，以图片的形式展示。2 spring 的配置文件：
<!-- JNDI 配置 -->
<bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
<property name="environment">
<props>
<prop key="java.naming.factory.initial">
weblogic.jndi.WLInitialContextFactory
</prop>
<prop key="java.naming.provider.url">
t3://localhost:7001
</prop>
<prop key="java.naming.factory.url.pkgs">
weblogic.jndi.factories
</prop>
</props>
</property>
</bean>
<!-- jms 连接工厂 ConnectionFactory 是在第11页图片里面要填写的jndi的名称-->
<bean id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="ConnectionFactory" />
<property name="jndiTemplate" ref="jndiTemplate"/>
</bean>
<!-- jms 队列 Queue 是在第11页图片里面要填写的jndi的名称-->
<bean id="jmsDestination" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="Queue" />
<property name="jndiTemplate" ref="jndiTemplate"/>
</bean>
<!-- jms模板-->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="defaultDestination" ref="jmsDestination" />
</bean>
<!-- 定义发送者-->
<bean id="sender" class="com.Sender">
<property name="jmsTemplate" ref="jmsTemplate" />
</bean>
<!-- 定义接收者-->
<bean id="receiver" class="com.Receiver">
</bean>
<!--接收者的监听器 -->
<bean id="maillistenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="jmsDestination" />
<property name="messageListener" ref="receiver" />
<property name="concurrentConsumers" value= "30"/>
<property name="autoStartup" value="true"/>
<property name="sessionTransacted" value="true"/>
</bean>
3 Sender.java类
//SimpleMimeObject 是自己定义的一个类
public class Sender{
private JmsTemplate jmsTemplate;
public void sendMessage(final SimpleMimeObject message) {
this.jmsTemplate.send(
new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createObjectMessage(message);//message 发送的消息
}
}
);
}
public JmsTemplate getJmsTemplate() {
return jmsTemplate;
}
public void setJmsTemplate(JmsTemplate jmsTemplate) {
this.jmsTemplate = jmsTemplate;
}
}
4 Receiver.java
public class Receiver implements MessageListener {
public void onMessage(Message message) {
if(message instanceof ObjectMessage) {
Object object = ((ObjectMessage)message).getObject();
if(object instanceof SimpleMimeObject) {
//接收者对消息进行处理
}
}
}
}
总结：sender 发送一个消息给jms服务器，sender就不用在管这个消息了，消息会被加到jms的队列里面。
receiver 在从队列里面接收消息，然后对这个消息进行处理。
页:
[1]