场景:BDM(实名制系统)同步数据到CRNS(实名制系统)

一,首先建个队列,队列名字为 bdm_empolyeeinfo_crns

二,applicationContext-rabbitmq.xml增加配置

    <!--同步BDM员工到实名制start-->
<task:executor id="baseEmpolyeeToCRNSTaskExecutor" pool-size="4-256" queue-capacity="128"/>
<bean id="baseEmployeeToCRNSRabbitConnectionFactory" class="com.rabbitmq.client.ConnectionFactory">
<property name="host" value="${rabbitmq.baseEmployeeToCRNS.host}"/>
<property name="port" value="${rabbitmq.baseEmployeeToCRNS.port}"/>
<property name="username" value="${rabbitmq.baseEmployeeToCRNS.username}"/>
<property name="password" value="${rabbitmq.baseEmployeeToCRNS.password}"/>
<property name="virtualHost" value="${rabbitmq.baseEmployeeToCRNS.VirtualHost}"/>
</bean>
<bean id="baseEmpolyeeToCRNSRabbitConnFactory"
class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
<constructor-arg ref="baseEmployeeToCRNSRabbitConnectionFactory"/>
<property name="channelCacheSize" value="25"/>
<property name="executor" ref="baseEmpolyeeToCRNSTaskExecutor"/>
</bean>
<!--通过指定下面的admin信息,当前producer中的exchange和queue会在rabbitmq服务器上自动生成 -->
<rabbit:admin connection-factory="baseEmpolyeeToCRNSRabbitConnFactory"/> <bean id="baseEmployeeToCRNSRabbitTemplate" class="org.springframework.amqp.rabbit.core.RabbitTemplate">
<constructor-arg ref="baseEmpolyeeToCRNSRabbitConnFactory"></constructor-arg>
<property name="exchange" value="${rabbitmq.baseEmployeeToCRNS.ExchangeName}"/>
</bean>
<rabbit:queue name="${rabbitmq.baseEmployeeToCRNS.QueueName}" durable="${rabbitmq.baseEmployeeToCRNS.QueueDurable}"
auto-delete="false" exclusive="false"/>
<rabbit:fanout-exchange name="${rabbitmq.baseEmployeeToCRNS.ExchangeName}"
durable="${rabbitmq.baseEmployeeToCRNS.ExchangeDurable}" auto-delete="false">
<rabbit:bindings>
<!-- 员工同步 -->
<rabbit:binding queue="${rabbitmq.baseEmployeeToCRNS.QueueName}"></rabbit:binding>
</rabbit:bindings>
</rabbit:fanout-exchange> <!--同步BDM员工到实名制end-->

三,config-rabbitmq.properties增加配置

############################ base 员工 rabitmq 推送 crns-start######################################
rabbitmq.baseEmployeeToCRNS.host=172.16.37.2
rabbitmq.baseEmployeeToCRNS.port=5672
rabbitmq.baseEmployeeToCRNS.username=test
rabbitmq.baseEmployeeToCRNS.password=123abc rabbitmq.baseEmployeeToCRNS.HostName=rabbitmq1.rabbit.com
rabbitmq.baseEmployeeToCRNS.VirtualHost=test
rabbitmq.baseEmployeeToCRNS.AutomaticRecoveryEnabled=true
rabbitmq.baseEmployeeToCRNS.deliveryMode=2
rabbitmq.baseEmployeeToCRNS.heartbeatTime=60 rabbitmq.baseEmployeeToCRNS.ExchangeName=bdm_crns
rabbitmq.baseEmployeeToCRNS.ExchangeDurable=true
rabbitmq.baseEmployeeToCRNS.ExchangeType=fanout rabbitmq.baseEmployeeToCRNS.QueueName=bdm_empolyeeinfo_crns
rabbitmq.baseEmployeeToCRNS.QueueDurable=true
rabbitmq.baseEmployeeToCRNS.RoutingKey=ebill ############################ base 员工 rabitmq 推送 crns-end######################################

四,service

五,发送消息

六,查看发送的消息

最新文章

  1. java 中包的概念,常量,静态与继承
  2. iOS 开发中的争议(一)
  3. chm文件突然乱码了
  4. Eclipse 设置SVN忽略文件
  5. oracle 返回第一个不为空的列的值
  6. 【caffe】mnist训练日志
  7. AngularJS概述&amp;指令
  8. javascript中字符串的常用方法
  9. 【Android UI设计与开发】9:滑动菜单栏(一)开源项目SlidingMenu的使用和示例
  10. Tomcat学习 HttpConnector和HttpProcessor启动流程和线程交互
  11. Intel Code Challenge Final Round (Div. 1 + Div. 2, Combined) B
  12. 无聊拿socket写的100以内的加法考试。。。
  13. C基础
  14. kafka文档翻译(一)
  15. 配置阿里云作为yum 源
  16. Winform获取当前程序名称或路径
  17. windows tcp端口映射或端口转发
  18. Json数据解析在Unity3d中的应用
  19. 面试题收集---grep和find的区别
  20. SharePoint列表模板(.stp)

热门文章

  1. 关于spring mvc 和struts2的描述与对比
  2. CentOS6.5下安装Redis2.8.6和phpredis2.2.4扩展
  3. AJPFX总结Collection集合(下)
  4. 【转】Iconfont
  5. Failure to transfer org.apache.maven.plugins:maven-compiler-plugin:jar:2.5.1
  6. /usr/bin/install -c -m 644 sample-config/httpd.conf /etc/httpd/conf.d/nagios.conf
  7. dataTables去掉搜索框和每页多少条框体,解决Cannot reinitialise DataTable问题
  8. RHEL6.4上Samba/NFS服务器简单配置
  9. CCS3超长文字显示省略号的方法
  10. 穷举(四):POJ上的两道穷举例题POJ 1411和POJ 1753