与不同框架整合时mybatis的使用区别 （对比activeMQ，见其他类似标题两篇）

与不同框架整合时mybatis的使用区别 （对比activeMQ，见其他类似标题两篇）

一般mybatis或者redis,等连接数据库的框架以及activeMQ应用规则都差不多：

1，配置好工厂

2，工厂注入模版配置好模版（这时候其实已经可以直接通过这个模版操作了）

3，如果spring提供了人性话的封装这个模版的类，或其他框架可以人性化整合这个模版，就可以更方便的使用，不用每次都获取模版然后操作

  比如1，没有用封装的模版（就直接用模版）

      2，有框架对其封装了就用封装后的操作入口即可，更方便：

      用spring封装了模版（配置的时候将模版注入spring的一个类），或者spring集成的比如mapper，这个mapper会自动识别id=sqlSession的模版，

      那么也就有了封装，就不必每次使用模版操作了，直接用mapper提供的人性化的操作入口即可

      3，像active的发送端的集成模版的集成类是自己写的，那么用的时候按照自己的操作方法用即可，接收端由于是监听所以不需要模版只要把工厂

      集成在监听里面即可（同时监听也要指明接收类）

 

      <bean id="topicSendConnectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">

<!-- <property name="brokerURL" value="udp://10.0.1.216:8123" /> -->

<!-- UDP传输方式 -->

<property name="brokerURL" value="tcp://10.0.1.222:61616" />

<!-- TCP传输方式 -->

<property name="useAsyncSend" value="true" />

</bean>

 

<bean id="topicListenConnectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">

<!-- <property name="brokerURL" value="udp://10.0.1.216:8123" /> -->

<!-- UDP传输方式需要在activemq上面做配置 -->

<property name="brokerURL" value="tcp://10.0.1.222:61616" />

<!-- TCP传输方式 -->

</bean>

<!-- 定义主题 -->

<bean id="myTopic" class="org.apache.activemq.command.ActiveMQTopic">

<constructor-arg value="esteelChat-mq1" />

</bean>

 

<bean id="messageConvertForSys" class="com.esteel.chat.mq.MessageConvertForSys" />

 

<!-- TOPIC send jms模板 -->

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">

<property name="connectionFactory" ref="topicSendConnectionFactory" />

<property name="defaultDestination" ref="myTopic" />

<property name="messageConverter" ref="messageConvertForSys" />

<!-- 发送模式 DeliveryMode.NON_PERSISTENT=1:非持久 ; DeliveryMode.PERSISTENT=2:持久 -->

<property name="deliveryMode" value="1" />

<property name="pubSubDomain" value="true" />

<!-- 开启订阅模式 -->

</bean>

<!-- 消息发送方 -->

<bean id="topicSender" class="com.esteel.chat.mq.MessageSender">

<property name="jmsTemplate" ref="jmsTemplate" />

</bean>

 

<!-- <bean id="springContextUtil" class="com.esteel.common.SpringContextUtil" /> -->

    

 

<!-- 消息接收方 -->

<bean id="topicReceiver" class="com.esteel.chat.mq.MessageReceiver" />

<!-- 主题消息监听容器，一经注册，自动监听 -->

<bean id="listenerContainer"

class="org.springframework.jms.listener.DefaultMessageListenerContainer">

<property name="connectionFactory" ref="topicListenConnectionFactory" />

<property name="pubSubDomain" value="true" />

<!-- true 订阅模式 -->

<property name="destination" ref="myTopic" />

<!-- 目的地 myTopic -->

<property name="subscriptionDurable" value="true" />

<!-- -这里是设置接收客户端的ID，在持久化时，但这个客户端不在线时，消息就存在数据库里，直到被这个ID的客户端消费掉 -->

<property name="clientId" value="clientId_esteelChat_17" />

<property name="messageListener" ref="topicReceiver" />

</bean>

       

 

///////发送封装

 

public class MessageSender {

 

private JmsTemplate jmsTemplate;

 

public void sendMessage(String msg) {

jmsTemplate.convertAndSend(msg);

}

 

public JmsTemplate getJmsTemplate() {

return jmsTemplate;

}

 

public void setJmsTemplate(JmsTemplate jmsTemplate) {

this.jmsTemplate = jmsTemplate;

}

 

}

 

//接收监听

 

 

@Controller

public class MessageReceiver implements MessageListener {

 

@Autowired

TbConOrdService tbConOrdService;

@Autowired

TbConOrdPriceService tbConOrdPriceService;

@Autowired

TbConObjService tbConObjService;

@Autowired

RedisService redisService;

//@Autowired

//private TbConOrdMapper tbConOrdMapper;

 

 

public void onMessage(Message m) {

}}