rabbitmq相关
2015-06-01 16:52
225 查看
1,rabbitMq支持持久化,如果rabbitMq服务器挂了,消息也不会丢失,当队列重启,都恢复了。
2,rabbitMq中几个重要的概念:虚拟主机(virtual host)、交换机(exchange)、队列(queue)、绑定(binding)
一个交换机持有一组交换机、队列和绑定;exchange上有路由表,这样才知道消息要放到哪个队列里,这个
路由表就是通过binding来设置的;
每一个消息都有一个称为路由键(routing key)的属性,路由表会根据消息中指定的路由键将消息放到
指定的队列中,其中会有一个模式匹配的规则:*与#,符号“#”匹配一个或多个词,符号“*”匹配不多不少一个词
绑定的作用是将发送消息的交换机与接受消息的队列进行连接。
3,mq服务器的相关说明,
mq运行产生的日志:一般在mq的安装目录/sbin/rabbitmq-defaults文件中会指定:
LOG_BASE=${SYS_PREFIX}/var/log/rabbitmq
设置mq中的用户、权限、交换机、绑定等使用./rabbitmqctl ...命令进行设置。
可参考一下这个博文:http://www.cnblogs.com/daizhj/archive/2010/10/21/1857374.html
rabbitmq的使用:
大致分三步:
1,设置vitual host,默认为'/'
rabbitmqctl add_vhosts test_v
2,新建账号,有一个默认的'guest'
rabbitmqctl add_user test 123456
3,给新建的账号分配访问权限:
rabbitmqctl set_permission -p test_v test "test_*" ".*" ".*"
这样test就可以访问虚拟主机为test_v上的资源了,且可以进行读写操作
2,rabbitMq中几个重要的概念:虚拟主机(virtual host)、交换机(exchange)、队列(queue)、绑定(binding)
一个交换机持有一组交换机、队列和绑定;exchange上有路由表,这样才知道消息要放到哪个队列里,这个
路由表就是通过binding来设置的;
每一个消息都有一个称为路由键(routing key)的属性,路由表会根据消息中指定的路由键将消息放到
指定的队列中,其中会有一个模式匹配的规则:*与#,符号“#”匹配一个或多个词,符号“*”匹配不多不少一个词
绑定的作用是将发送消息的交换机与接受消息的队列进行连接。
3,mq服务器的相关说明,
mq运行产生的日志:一般在mq的安装目录/sbin/rabbitmq-defaults文件中会指定:
LOG_BASE=${SYS_PREFIX}/var/log/rabbitmq
设置mq中的用户、权限、交换机、绑定等使用./rabbitmqctl ...命令进行设置。
可参考一下这个博文:http://www.cnblogs.com/daizhj/archive/2010/10/21/1857374.html
springmvc中使用rabbitMq: <!--首先指定一个连接工厂,指定地址(IP,PORT)、名称、密码与虚拟主机名,后面几种是在mq服务器上进行配置的--> <rabbit:connection-factory id="connectionFactory_stock" addresses="rabbit100.gzb.local:5672,rabbit102.gzb.local:5672,rabbit106.gzb.local:5672" username="test" password="test" virtual-host="/stock"/> <rabbit:admin connection-factory="connectionFactory_stock" /> <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <!-- 核心线程数,默认为1 --> <property name="corePoolSize" value="10" /> <!-- 最大线程数,默认为Integer.MAX_VALUE --> <property name="maxPoolSize" value="50" /> <!-- 队列最大长度,一般需要设置值>=notifyScheduledMainExecutor.maxNum;默认为Integer.MAX_VALUE --> <property name="queueCapacity" value="1000" /> <!-- 线程池维护线程所允许的空闲时间,默认为60s --> <property name="keepAliveSeconds" value="300" /> <!-- 线程池对拒绝任务(无线程可用)的处理策略,目前只支持AbortPolicy、CallerRunsPolicy;默认为后者 --> <property name="rejectedExecutionHandler"> <!-- AbortPolicy:直接抛出java.util.concurrent.RejectedExecutionException异常 --> <!-- CallerRunsPolicy:主线程直接执行该任务,执行完之后尝试添加下一个任务到线程池中,可以有效降低向线程池内添加任务的速度 --> <!-- DiscardOldestPolicy:抛弃旧的任务、暂不支持;会导致被丢弃的任务无法再次被执行 --> <!-- DiscardPolicy:抛弃当前任务、暂不支持;会导致被丢弃的任务无法再次被执行 --> <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" /> </property> </bean> <rabbit:queue id="stock_settlement_exchange_queue" durable="true" auto-delete="false" exclusive="false" name="stock_settlement_exchange_queue"/> <!-- exchange queue binging key 绑定 --> <rabbit:topic-exchange name="stock_settlement_exchange" durable="true" auto-delete="false" id="stock_settlement_exchange"> <rabbit:bindings> <rabbit:binding queue="stock_settlement_exchange_queue" pattern="stocktrade.settlement.*" /> </rabbit:bindings> </rabbit:topic-exchange> <!-- 默认消息处理类,可以重写 --> <bean id="incomeMessageHandler" class="com.jrj.rabbitmq.message.MessageHandler"></bean> <!-- 用于消息的监听的代理类MessageListenerAdapter --> <bean id="messageQueueListenerAdapter_stock" class="org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter"> <constructor-arg ref="incomeMessageHandler" /> <property name="defaultListenerMethod" value="handleMessage"></property> <property name="messageConverter" ref="messageConverter_stock"/> </bean> <bean id="messageConverter_stock" class="org.springframework.amqp.support.converter.SimpleMessageConverter"/> <!-- 监听容器 --> <rabbit:listener-container connection-factory="connectionFactory_stock" acknowledge="auto" task-executor="taskExecutor"> <rabbit:listener queues="stock_settlement_exchange_queue" ref="messageQueueListenerAdapter_stock" /> </rabbit:listener-container>
rabbitmq的使用:
大致分三步:
1,设置vitual host,默认为'/'
rabbitmqctl add_vhosts test_v
2,新建账号,有一个默认的'guest'
rabbitmqctl add_user test 123456
3,给新建的账号分配访问权限:
rabbitmqctl set_permission -p test_v test "test_*" ".*" ".*"
这样test就可以访问虚拟主机为test_v上的资源了,且可以进行读写操作
相关文章推荐
- Sharepoint Workflow 获取中文栏的问题
- window.location.href/replace/reload()--页面跳转+替换+刷新
- C语言笔记(四)
- 百度的富文本编辑器UEDITOR
- public和private注释
- android app.Service 关键问题
- Delegate,Action Sheet, Alert
- OSG项目经验2<在场景中添加文字面版>
- CodeForge源码分享
- Node.js安装和入门
- 【C语言探索之旅】 第三部分第一课:SDL开发游戏之安装SDL
- python直接按行读取gz压缩文件中的文本文件的数据
- Java编码问题汇总
- The Internet Communications Engine (Ice) 跨平台异构通讯方案 第二弹-Hello world! - Uzumaki
- “ 戏"说 明星”与“麻将
- Cannot resolve the collation conflict between "SQL_Latin1_Gen
- DIKW模型
- file压缩
- 人人都是网站分析师:从分析师的视角理解网站和解读数据
- break continue switch 语句的使用