mq

千万别读MQ！！！特别垃圾的大学！虽然我不了解IT的情况，但是就知名度来讲，肯定是UTS更好但是听说UTS 的IT非常容易挂客，有个什么魔鬼老师来着这边就业没有PR你什么学校毕业都没用，这边不看文凭也不看学校，不是local就看你的英文水平和PR。

美的冰箱这种变频的坏了，换一个多少钱可以叫他们的售后服务来看一下，他说是多少应该他们知道。

序列号：C8PJMQN0DTC0设备名称：iPhone 4S容 量：16GB颜 色：黑色类 型：iPhone4,1代 号：n94ap型 号：MD235激活状态：已激活（2012年11月23日）电话支持：未过期（2013年02月21日）硬件保修：未过期（2013年11月22日）生产日期：2012年11月04日 - 2012年11月10日生产工厂：中国备 注：此型号大部分为无锁机,无锁版本国内可以2网(联通+移动)通用,有锁版本可以使用卡贴

RMQ线上集群（ v3.6.12 ）purge一个大量消息堆积（100W+）的队列时，有可能导致客户端报大量发送超时异常。 purge 操作实际发生的事情（ rabbit_amqqueue_process .erl）： handle_call(purge, _From, State = #q{backing_queue = BQ, backing_queue_state = BQS}) -> {Count, BQS1} = BQ:purge(BQS) , ... BQ默认对应 rabbit_variable_queue 模块： msg_store_remove(MSCState, IsPersistent, MsgIds) -> with_immutable_msg_store_state( MSCState, IsPersistent, fun (MCSState1) -> rabbit_msg_store :remove(MsgIds, MCSState1) end). 也就是purge操作，最终是由 rabbit_msg_store 进程来进行操作的。 rabbit_msg_store 进程，每个节点只有一个，因此容易成为瓶颈。 rabbitmq 进程间通信采用 credit_flow 机制，一般一条持久化消息发送到持久化队列的大致过程如下： rabbit_reader → rabbit_channel → rabbit_amqqueue_process → rabbit_msg_store 当 rabbit_msg_store 进程忙于大量消息的purge操作时，不能及时处理其上游 rabbit_amqqueue_process 的消息，这会导致其上游 rabbit_amqqueue_process 很快耗光其 credit 值，从而造成 flow。同理， 当 rabbit_amqqueue_process 进程由于 flow 被 block 住，不能及时处理其上游 rabbit_channel 的消息，导致 rabbit_channel 很快耗光其 credit 值，也造成 flow。最终限流状态会一直追溯到最上层 connection。 此时客户端发送会卡顿（表现出等待confirm超时等异常） 因此， 对于线上有业务量的RMQ集群，如果有大量消息堆积的队列需要清理，最好不要直接purge，有可能对线上业务造成影响 。 最保险的清理方式，起 Consumers 消费（接收即丢弃） 线上业务集群节点 TcpExt.pruneCalled 指标报警，同时发现有一队列处于 flow 状态，进而判断持久化进程 rabbit_msg_store 出现瓶颈，通过 sar 工具发现以下异常： 最终定位到节点对应的宿主机底层IO有问题，及时进行规避。 Finding bottlenecks with RabbitMQ 3.3 Purge a large queue is slow

生化危机2重制版Magnum获取必须要获得桃心钥匙(克莱尔)或者梅花钥匙(里昂)才行。 传说门 >>>全武器获取攻略<<< 生化危机2重制版MQ11获取方法介绍 1.最早可以在【S.T.A.R.S.办公室】看到这把武器，但在完成地下/停车场部分之前是不能解锁这把武器的，必须要获得【桃心钥匙(克莱尔)】或者【梅花钥匙(里昂)】才行。 2.首先需要获得【红色宝石】。前往东侧二层【图书馆】然后在桌子上找到一本【红皮书】。 3.拿到【红皮书】后回到你找到安全柜钥匙卡的那个房间。在二层的【美术室】里可以找到一尊雕像——缺少了一只手，雕像的手就在旁边的桌子上的。 4.把【红皮书】放在手里，再把手装回雕像上，之后可以获得【权杖】，从背包里检查【权杖】可以获得【红色宝石】。 5.然后要把【红色宝石】与【珠宝盒】组合在一起，珠宝盒可以从【审讯室/指认室】里获得。 6.注意，同样必须从地下停车场区域返回之后才可以完成。 7.组合之后可以获得【S.T.A.R.S.徽章】，从背包里检查它就会变成一个【USB驱动器】，之后在【S.T.A.R.S.办公室】的电脑上使用，即可打开武器储物柜。 8.前往【S.T.A.R.S.办公室】取回武器。

rabbitmq有三种模式： 单机模式，普通集群模式，镜像集群模式 kafka架构：多个broker组成，每个broker是一个节点；创建一个topic，这个topic可以划分为多个partition，每个partition可以存在于不同的broker上，每个partition就放一部分数据。 它是一个分布式消息队列，就是说一个topic的数据，是分散放在多个机器上的，每个机器就放一部分数据。 kafka 0.8以前，是没有HA机制的，就是任何一个broker宕机了，那个broker上的partition就废了，没法写也没法读，没有什么高可用性可言。 kafka 0.8以后，提供了HA机制，就是replica副本机制。每个partition的数据都会同步到吉他机器上，形成自己的多个replica副本。然后所有replica会选举一个leader出来，那么生产和消费都跟这个leader打交道，然后其他replica就是follower。写的时候，leader会负责把数据同步到所有follower上去，读的时候就直接读leader上数据即可。kafka会均匀的将一个partition的所有replica分布在不同的机器上，从而提高容错性。 如果某个broker宕机了也没事，它上面的partition在其他机器上都有副本的，如果这上面有某个partition的leader，那么此时会重新选举一个新的leader出来，大家继续读写那个新的leader即可。这就有所谓的高可用性了。 写数据的时候，生产者就写leader，然后leader将数据落地写本地磁盘，接着其他follower自己主动从leader来pull数据。一旦所有follower同步好数据了，就会发送ack给leader，leader收到所有follower的ack之后，就会返回写成功的消息给生产者。 消费的时候，只会从leader去读，但是只有当消息已经被所有follower都同步成功返回ack的时候，这个消息才会被消费者读到。 kafka重复消费的情况： kafka有个offset的概念，就是每个消息写进去，都有一个offset，代表他的序号，然后consumer消费了数据之后，每隔一段时间，会把自己消费过的消息的offset提交一下，下次重启时，从上次消费到的offset来继续消费。但是offset没来得及提交就重启，这部分会再次消费一次。 怎么保证消息队列消费的幂等性： 丢数据，mq一般分为两种，要么是mq自己弄丢了，要么是我们消费的时候弄丢了 拆分多个queue，每个queue一个consumer，就是多一些queue而已，确实是麻烦点；或者就一个queue但是对应一个consumer，然后这个consumer内部用内存队列做排队，然后分发给底层不同的worker来处理 写入一个partition中的数据一定是有序的，生产者在写的时候 ，可以指定一个key，比如指定订单id作为key，这个订单相关数据一定会被分发到一个partition中去。消费者从partition中取出数据的时候也一定是有序的，把每个数据放入对应的一个内存队列，一个partition中有几条相关数据就用几个内存队列，消费者开启多个线程，每个线程处理一个内存队列。

RockerMQ在k8s的部署有两种方式， 一种是使用operator 在k8s集群中部署，可参考 operation项目 ； 一种是编写简单的k8s配置文件，在rocketmq的docker项目中有提供模板。 这里我们希望使用单机版k8s部署一套低配置rockerMQ, 仅启动一个nameservice和1个broker，我们将使用 rocketmq-docker项目 提供的模板来完成。 apiVersion: apps/v1 kind: Deployment metadata: name: rocketmq spec: replicas: 1 selector: matchLabels: app: rocketmq template: metadata: labels: app: rocketmq spec: containers: - name: broker image: apacherocketmq/rocketmq:4.6.0 command: [&quot.sh","mqbroker", "-n","localhost:9876"] imagePullPolicy: IfNotPresent ports: - containerPort: 10909 - containerPort: 10911 env: - name: JAVA_OPT value: -server -XX:ParallelGCThreads=1 volumeMounts: - mountPath: /home/rocketmq/logs name: brokeroptlogs - mountPath: /home/rocketmq/store name: brokeroptstore - name: namesrv image: apacherocketmq/rocketmq:4.6.0 command: ["sh","mqnamesrv"] imagePullPolicy: IfNotPresent ports: - containerPort: 9876 volumeMounts: - mountPath: /home/rocketmq/logs name: namesrvoptlogs volumes: - name: brokeroptlogs emptyDir: {} - name: brokeroptstore emptyDir: {} - name: namesrvoptlogs emptyDir: {} - name: namesrvoptstore emptyDir: {} apiVersion: v1 kind: Service metadata: name: rocketmqservice spec: type: NodePort ports: - name: namesrv port: 9876 targetPort: 9876 nodePort: 32000 selector: app: rocketmq notes： 签名异常问题 Caused by: org.apache.rocketmq.acl.common.AclException: [10015:signature-failed] unable to calculate a request signature. error=Algorithm HmacSHA1 not available 手动方案I，在tool.sh 中${JAVA_HOME}/jre/lib/ext后加上ext文件夹的绝对路径（jdk路径） 最终方案： 手动的方式，很不方便，经过检查，实际问题是由于路径上的${JAVA_HOME}变量为空，导致无法找到etx路径。所以，我们通过k8s的方式传入JAVA_HOME环境便令就可以了。如下图： 3.2 添加订阅组 订阅组 可以用来实现消费的loadbalance，同一订阅组的消费者分享所有的读队列。 创建订阅组使用updateSubGroup 命令，所需参数如下： 执行命令新建一个授权服务的消费组 ./mqadmin updateSubGroup -b localhost:10911 -n localhost:9876 -g GID_authorize 执行结果：

然而，如果不限制每次push给消费者的消息个数将会是危险的，过多的消息会导致消费者客户端资源耗尽。尤其是当消息的消费速度显著慢于消息的分发速度时。而且如果不加以限制的话会导致消息被单一的消费者消费，其他消费者处于空闲状态，我们就遇到过这种情况，activemq默认的 缓冲区大小1000条message， 有时其中一个消费者缓冲区中有800多条message，而另一个消费者处于空闲状态，这就导致资源没有充分利用，而且降低了消息的处理速度。 为了避免这种情况，ActiveMQ使用预取极限（prefetch limit）来限制一次性分发给单个消费者的最大消息个数。消费者则使用预取极限（prefetch limit）来设置其消息缓冲区的大小。 可以在ActiveMQConnectionFactory或ActiveMQConnection上指定ActiveMQPrefetchPolicy的实例，具体有四个配置： 有两种方法可以配置prefetch limit： 前面也提到过，prefetch limit也不是越大越好，能够很快处理的Message，相应的consumer我们可以将prefetch limit设置的较大一点，而处理比较慢的Message，相应的consumer最好将prefetch limit设置为1，这可确保消费者一次只处理一条消息，Message不会pending到缓冲区，并且能够充分利用多个Message Consumer的资源。如果将prefetch limit设置为0，将导致consumer一次一个地轮询pull消息，而不是将消息push到消费者缓冲区，前面提到过这种方式会增加时延，间接的降低了消息的处理速度。

它们的含义如下：MQS：Modular Quadlock System，模块化四插接系统，是一种汽车行业常用的连接器系统，通常用于连接汽车电气系统中的线束和设备。MCON：Modular CONnector，模块化连接器，是一种多功能连接器系统，适用于多种应用领域，如汽车、医疗、工业和通信等。MCP：Multi-Contact Pro系列，多接触点连接器，是一种高密度连接器系统，具有优异的信号传输性能，适用于高速数据传输和信号处理等应用。这些端子分类都是TE公司自己的产品系列，每个系列都有其特定的设计和应用场景，可以根据不同的需要选择合适的产品。

java工作流和mq相结合可以采用以下3种方式：1、在工作流中使用消息队列：可以使用消息队列作为工作流中的任务处理引擎，将任务分配到消息队列中，并通过消息队列中的消息通知任务执行状态或结果。2、在消息队列中使用工作流：可以使用工作流作为消息队列中的消息处理引擎，将消息作为工作流中的任务，通过工作流引擎执行任务，并根据任务执行结果发送消息通知。3、工作流和消息队列相互协作：可以将工作流和消息队列结合起来，实现复杂的任务处理和协作场景，例如多个任务之间的依赖关系、任务执行的顺序控制、任务执行的并行处理等。

我们的服务器从单机发展到拥有多台机器的分布式系统，各个系统之前需要借助于网络进行通信，原有单机中相对可靠的方法调用以及进程间通信方式已经没有办法使用，同时网络环境也是不稳定的，造成了我们多个机器之间的数据同步问题，这就是典型的分布式事务问题。 在分布式事务中事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。分布式事务就是要保证不同节点之间的数据一致性。 1、2PC(二阶段提交)方案 - 强一致性 2、3PC(三阶段提交)方案 3、TCC （Try-Confirm-Cancel）事务 - 最终一致性 4、Saga事务 - 最终一致性 5、本地消息表 - 最终一致性 6、MQ事务 - 最终一致性 消息的生产方，除了维护自己的业务逻辑之外，同时需要维护一个消息表。这个消息表里面记录的就是需要同步到别的服务的信息，当然这个消息表，每个消息都有一个状态值，来标识这个消息有没有被成功处理。 发送放的业务逻辑以及消息表中数据的插入将在一个事务中完成，这样避免了业务处理成功 + 事务消息发送失败，或业务处理失败 + 事务消息发送成功，这个问题。 举个栗子： 我们假定目前有两个服务，订单服务，购物车服务，用户在购物车中对几个商品进行合并下单，之后需要情况购物车中刚刚已经下单的商品信息。 1、消息的生产方也就是订单服务，完成了自己的逻辑(对商品进行下单操作)然后把这个消息通过 mq 发送到需要进行数据同步的其他服务中，也就是我们栗子中的购物车服务。 2、其他服务(购物车服务)会监听这个队列； 1、如果收到这个消息，并且数据同步执行成功了，当然这也是一个本地事务，就通过 mq 回复消息的生产方(订单服务)消息已经处理了，然后生产方就能标识本次事务已经结束。如果是一个业务上的错误,就回复消息的生产方，需要进行数据回滚了。 2、很久没收到这个消息，这种情况是不会发生的，消息的发送方会有一个定时的任务，会定时重试发送消息表中还没有处理的消息； 3、消息的生产方(订单服务)如果收到消息回执； 1、成功的话就修改本次消息已经处理完，也就是本次分布式事务的同步已经完成； 2、如果消息的结果是执行失败，同时在本地回滚本次事务，标识消息已经处理完成； 3、如果消息丢失，也就是回执消息没有收到，这种情况也不太会发生，消息的发送方(订单服务)会有一个定时的任务，定时重试发送消息表中还没有处理的消息，下游的服务需要做幂等，可能会收到多次重复的消息，如果一个回复消息生产方中的某个回执信息丢失了，后面持续收到生产方的 mq 消息，然后再次回复消息的生产方回执信息，这样总能保证发送者能成功收到回执，消息的生产方在接收回执消息的时候也要做到幂等性。 这里有两个很重要的操作： 1、服务器处理消息需要是幂等的，消息的生产方和接收方都需要做到幂等性； 2、发送放需要添加一个定时器来遍历重推未处理的消息，避免消息丢失，造成的事务执行断裂。 该方案的优缺点 优点： 1、在设计层面上实现了消息数据的可靠性，不依赖消息中间件，弱化了对 mq 特性的依赖。 2、简单，易于实现。 缺点： 主要是需要和业务数据绑定到一起，耦合性比较高，使用相同的数据库，会占用业务数据库的一些资源。 下面分析下几种消息队列对事务的支持 RocketMQ 中的事务，它解决的问题是，确保执行本地事务和发消息这两个操作，要么都成功，要么都失败。并且，RocketMQ 增加了一个事务反查的机制，来尽量提高事务执行的成功率和数据一致性。 主要是两个方面，正常的事务提交和事务消息补偿 正常的事务提交 1、发送消息（half消息），这个 half 消息和普通消息的区别，在事务提交 之前，对于消费者来说，这个消息是不可见的。 2、MQ SERVER写入信息，并且返回响应的结果； 3、根据MQ SERVER响应的结果，决定是否执行本地事务,如果MQ SERVER写入信息成功执行本地事务，否则不执行； 如果MQ SERVER没有收到 Commit 或者 Rollback 的消息，这种情况就需要进行补偿流程了 补偿流程 1、MQ SERVER如果没有收到来自消息发送方的 Commit 或者 Rollback 消息，就会向消息发送端也就是我们的服务器发起一次查询，查询当前消息的状态； 2、消息发送方收到对应的查询请求，查询事务的状态，然后把状态重新推送给MQ SERVER，MQ SERVER就能之后后续的流程了。 相比于本地消息表来处理分布式事务，MQ 事务是把原本应该在本地消息表中处理的逻辑放到了 MQ 中来完成。 Kafka 中的事务解决问题，确保在一个事务中发送的多条信息，要么都成功，要么都失败。也就是保证对多个分区写入操作的原子性。 通过配合 Kafka 的幂等机制来实现 Kafka 的 Exactly Once，满足了读取-处理-写入这种模式的应用程序。当然 Kafka 中的事务主要也是来处理这种模式的。 什么是读取-处理-写入模式呢？ 栗如：在流计算中，用 Kafka 作为数据源，并且将计算结果保存到 Kafka 这种场景下，数据从 Kafka 的某个主题中消费，在计算集群中计算，再把计算结果保存在 Kafka 的其他主题中。这个过程中，要保证每条消息只被处理一次，这样才能保证最终结果的成功。Kafka 事务的原子性就保证了，读取和写入的原子性，两者要不一起成功，要不就一起失败回滚。 这里来分析下 Kafka 的事务是如何实现的 它的实现原理和 RocketMQ 的事务是差不多的，都是基于两阶段提交来实现的，在实现上可能更麻烦 先来介绍下事务协调者，为了解决分布式事务问题，Kafka 引入了事务协调者这个角色，负责在服务端协调整个事务。这个协调者并不是一个独立的进程，而是 Broker 进程的一部分，协调者和分区一样通过选举来保证自身的可用性。 Kafka 集群中也有一个特殊的用于记录事务日志的主题，里面记录的都是事务的日志。同时会有多个协调者的存在，每个协调者负责管理和使用事务日志中的几个分区。这样能够并行的执行事务，提高性能。 下面看下具体的流程 事务的提交 1、协调者设置事务的状态为PrepareCommit，写入到事务日志中； 2、协调者在每个分区中写入事务结束的标识，然后客户端就能把之前过滤的未提交的事务消息放行给消费端进行消费了； 事务的回滚 1、协调者设置事务的状态为PrepareAbort，写入到事务日志中； 2、协调者在每个分区中写入事务回滚的标识，然后之前未提交的事务消息就能被丢弃了； 这里引用一下【消息队列高手课中的图片】 RabbitMQ 中事务解决的问题是确保生产者的消息到达MQ SERVER，这和其他 MQ 事务还是有点差别的，这里也不展开讨论了。 先来分析下一条消息在 MQ 中流转所经历的阶段。 生产阶段 ：生产者产生消息，通过网络发送到 Broker 端。 存储阶段 ：Broker 拿到消息，需要进行落盘，如果是集群版的 MQ 还需要同步数据到其他节点。 消费阶段 ：消费者在 Broker 端拉数据，通过网络传输到达消费者端。 发生网络丢包、网络故障等这些会导致消息的丢失 在生产者发送消息之前，通过channel.txSelect开启一个事务，接着发送消息， 如果消息投递 server 失败，进行事务回滚channel.txRollback，然后重新发送， 如果 server 收到消息，就提交事务channel.txCommit 不过使用事务性能不好，这是同步操作，一条消息发送之后会使发送端阻塞，以等待RabbitMQ Server的回应，之后才能继续发送下一条消息，生产者生产消息的吞吐量和性能都会大大降低。 使用确认机制，生产者将信道设置成 confirm 确认模式，一旦信道进入 confirm 模式，所有在该信道上面发布的消息都会被指派一个唯一的ID（从1开始），一旦消息被投递到所有匹配的队列之后，RabbitMQ 就会发送一个确认（Basic.Ack）给生产者（包含消息的唯一 deliveryTag 和 multiple 参数），这就使得生产者知晓消息已经正确到达了目的地了。 multiple 为 true 表示的是批量的消息确认，为 true 的时候，表示小于等于返回的 deliveryTag 的消息 id 都已经确认了，为 false 表示的是消息 id 为返回的 deliveryTag 的消息，已经确认了。 确认机制有三种类型 1、同步确认 2、批量确认 3、异步确认 同步模式的效率很低，因为每一条消息度都需要等待确认好之后，才能处理下一条； 批量确认模式相比同步模式效率是很高，不过有个致命的缺陷，一旦回复确认失败，当前确认批次的消息会全部重新发送，导致消息重复发送； 异步模式就是个很好的选择了，不会有同步模式的阻塞问题，同时效率也很高，是个不错的选择。 Kafaka 中引入了一个 broker。 broker 会对生产者和消费者进行消息的确认，生产者发送消息到 broker，如果没有收到 broker 的确认就可以选择继续发送。 只要 Producer 收到了 Broker 的确认响应，就可以保证消息在生产阶段不会丢失。有些消息队列在长时间没收到发送确认响应后，会自动重试，如果重试再失败，就会以返回值或者异常的方式告知用户。 只要正确处理 Broker 的确认响应，就可以避免消息的丢失。 RocketMQ 提供了3种发送消息方式，分别是： 同步发送：Producer 向 broker 发送消息，阻塞当前线程等待 broker 响应 发送结果。 异步发送：Producer 首先构建一个向 broker 发送消息的任务，把该任务提交给线程池，等执行完该任务时，回调用户自定义的回调函数，执行处理结果。 Oneway发送：Oneway 方式只负责发送请求，不等待应答，Producer 只负责把请求发出去，而不处理响应结果。 在存储阶段正常情况下，只要 Broker 在正常运行，就不会出现丢失消息的问题，但是如果 Broker 出现了故障，比如进程死掉了或者服务器宕机了，还是可能会丢失消息的。 防止在存储阶段消息额丢失，可以做持久化，防止异常情况(重启，关闭，宕机)。。。 RabbitMQ 持久化中有三部分： 消息的持久化，在投递时指定 delivery_mode=2（1是非持久化），消息的持久化，需要配合队列的持久，只设置消息的持久化，重启之后队列消失，继而消息也会丢失。所以如果只设置消息持久化而不设置队列的持久化意义不大。 对于持久化，如果所有的消息都设置持久化，会影响写入的性能，所以可以选择对可靠性要求比较高的消息进行持久化处理。 不过消息持久化并不能百分之百避免消息的丢失 比如数据在落盘的过程中宕机了，消息还没及时同步到内存中，这也是会丢数据的，这种问题可以通过引入镜像队列来解决。 镜像队列的作用：引入镜像队列，可已将队列镜像到集群中的其他 Broker 节点之上，如果集群中的一个节点失效了，队列能够自动切换到镜像中的另一个节点上来保证服务的可用性。(更细节的这里不展开讨论了) 操作系统本身有一层缓存，叫做 Page Cache，当往磁盘文件写入的时候，系统会先将数据流写入缓存中。 Kafka 收到消息后也会先存储在也缓存中(Page Cache)中，之后由操作系统根据自己的策略进行刷盘或者通过 fsync 命令强制刷盘。如果系统挂掉，在 PageCache 中的数据就会丢失。也就是对应的 Broker 中的数据就会丢失了。 处理思路 1、控制竞选分区 leader 的 Broker。如果一个 Broker 落后原先的 Leader 太多，那么它一旦成为新的 Leader，必然会造成消息的丢失。 2、控制消息能够被写入到多个副本中才能提交，这样避免上面的问题1。 1、将刷盘方式改成同步刷盘； 2、对于多个节点的 Broker，需要将 Broker 集群配置成：至少将消息发送到 2 个以上的节点，再给客户端回复发送确认响应。这样当某个 Broker 宕机时，其他的 Broker 可以替代宕机的 Broker，也不会发生消息丢失。 消费阶段就很简单了，如果在网络传输中丢失，这个消息之后还会持续的推送给消费者，在消费阶段我们只需要控制在业务逻辑处理完成之后再去进行消费确认就行了。 总结：对于消息的丢失，也可以借助于本地消息表的思路，消息产生的时候进行消息的落盘，长时间未处理的消息，使用定时重推到队列中。 消息在 MQ 中的传递，大致可以归类为下面三种： 1、At most once: 至多一次。消息在传递时，最多会被送达一次。是不安全的，可能会丢数据。 2、At least once: 至少一次。消息在传递时，至少会被送达一次。也就是说，不允许丢消息，但是允许有少量重复消息出现。 3、Exactly once：恰好一次。消息在传递时，只会被送达一次，不允许丢失也不允许重复，这个是最高的等级。 大部分消息队列满足的都是At least once，也就是可以允许重复的消息出现。 我们消费者需要满足幂等性,通常有下面几种处理方案 1、利用数据库的唯一性 根据业务情况，选定业务中能够判定唯一的值作为数据库的唯一键，新建一个流水表，然后执行业务操作和流水表数据的插入放在同一事务中，如果流水表数据已经存在，那么就执行失败，借此保证幂等性。也可先查询流水表的数据，没有数据然后执行业务，插入流水表数据。不过需要注意，数据库读写延迟的情况。 2、数据库的更新增加前置条件 3、给消息带上唯一ID 每条消息加上唯一ID,利用方法1中通过增加流水表，借助数据库的唯一性来处理重复消息的消费。

前言 开源社区有好多优秀的队列中间件，比如RabbitMQ和Kafka，每个队列都貌似有其特性，在进行工程选择时，往往眼花缭乱，不知所措。对于RabbitMQ和Kafka，到底应该选哪个？ RabbitMQ架构 概念 RabbitMQ是一个分布式系统 broker：每个节点运行的服务程序，功能为维护该节点的队列的增删以及转发队列操作请求。 master queue：每个队列都分为一个主队列和若干个镜像队列。 mirror queue：镜像队列，作为master queue的备份。在master queue所在节点挂掉之后，系统把mirror queue提升为master queue，负责处理客户端队列操作请求。注意，mirror queue只做镜像，设计目的不是为了承担客户端读写压力。 如上图所示，集群中有两个节点，每个节点上有一个broker，每个broker负责本机上队列的维护，并且borker之间可以互相通信。集群中有两个队列A和B，每个队列都分为master queue和mirror queue（备份）。那么队列上的生产消费怎么实现的呢？ 队列消费 如上图有两个consumer消费队列A，这两个consumer连在了集群的不同机器上。RabbitMQ集群中的任何一个节点都拥有集群上所有队列的元信息，所以连接到集群中的任何一个节点都可以，主要区别在于有的consumer连在master queue所在节点，有的连在非master queue节点上。 因为mirror queue要和master queue保持一致，故需要同步机制，正因为一致性的限制，导致所有的读写操作都必须都操作在master queue上（想想，为啥读也要从master queue中读？和数据库读写分离是不一样的。），然后由master节点同步操作到mirror queue所在的节点。即使consumer连接到了非master queue节点，该consumer的操作也会被路由到master queue所在的节点上，这样才能进行消费。 队列生产 原理和消费一样，如果连接到非 master queue 节点，则路由过去。 不足 由于master queue单节点，导致性能瓶颈，吞吐量受限。虽然为了提高性能，内部使用了Erlang这个语言实现，但是终究摆脱不了架构设计上的致命缺陷。 Kafka 说实话，Kafka我觉得就是看到了RabbitMQ这个缺陷才设计出的一个改进版，改进的点就是：把一个队列的单一master变成多个master，即一台机器扛不住qps，那么我就用多台机器扛qps，把一个队列的流量均匀分散在多台机器上不就可以了么？注意，多个master之间的数据没有交集，即一条消息要么发送到这个master queue，要么发送到另外一个master queue。 这里面的每个master queue 在Kafka中叫做Partition，即一个分片。一个队列有多个主分片，每个主分片又有若干副分片做备份，同步机制类似于RabbitMQ。 如上图，我们省略了不同的queue，假设集群上只有一个queue（Kafka中叫Topic）。每个生产者随机把消息发送到主分片上，之后主分片再同步给副分片。 队列读取的时候虚拟出一个Group的概念，一个Topic内部的消息，只会路由到同Group内的一个consumer上，同一个Group中的consumer消费的消息是不一样的；Group之间共享一个Topic，看起来就是一个队列的多个拷贝。所以，为了达到多个Group共享一个Topic数据，Kafka并不会像RabbitMQ那样消息消费完毕立马删除，而是必须在后台配置保存日期，即只保存最近一段时间的消息，超过这个时间的消息就会从磁盘删除，这样就保证了在一个时间段内，Topic数据对所有Group可见（这个特性使得Kafka非常适合做一个公司的数据总线）。队列读同样是读主分片，并且为了优化性能，消费者与主分片有一一的对应关系，如果消费者数目大于分片数，则存在某些消费者得不到消息。 由此可见，Kafka绝对是为了高吞吐量设计的，比如设置分片数为100，那么就有100台机器去扛一个Topic的流量，当然比RabbitMQ的单机性能好。 总结 本文只做了Kafka和RabbitMQ的对比，但是开源队列岂止这两个，ZeroMQ，RocketMQ，JMQ等等，时间有限也就没有细看，故不在本文比较范围之内。 所以，别再被这些五花八门的队列迷惑了，从架构上找出关键差别，并结合自己的实际需求（比如本文就只单单从吞吐量一个需求来考察）轻轻松松搞定选型。最后总结如下： 吞吐量较低：Kafka和RabbitMQ都可以。 吞吐量高：Kafka。

一、MSMQ介绍和安装消息队列　　使用消息队列的优点：稳定、消息优先级、脱机能力以及安全性。　　消息队列分为用户创建的队列(专用队列)和系统队列，看下图所示(myQueue为自己创建的消息队列,msmqtriggersnotifiations为通用队列)：　　对消息队列有了简单的了解后，使用MSMQ进行软件开发需要安装MSMQ，安装完后就该进入实际的开发阶段。具体的安装过程就是在控制面板里“添加/删除程序”下“添加/删除Windows组件”，完成添加就OK。安装完成后就可以通过交互界添加新的消息队列，详细如下图：　　出了上面这种交互界面来创建MSMQ外，也可以通过编程来完成，.NET框架里的MessageQueue类下有一静态方法Create，用来完成消息队列的创建，其定义如下：　　1// 2// 摘要: 3// 在指定的路径中创建非事务性“消息队列”队列。 4// 5// 参数: 6// path: 7// 要创建的队列的路径。 8// 9// 返回结果: 10// 表示新队列的 System.Messaging.MessageQueue。 11public static MessageQueue Create(string path); 12// 13// 摘要: 14// 在指定的路径中创建事务性或非事务性“消息队列”队列。 15// 16// 参数: 17// transactional: 18// 如果创建事务性队列，为 true；如果创建非事务性队列，则为 false。 19// 20// path: 21// 要创建的队列的路径。 22// 23// 返回结果: 24// 表示新队列的 System.Messaging.MessageQueue。 25public static MessageQueue Create(string path, bool transactional);　　实现消息队列的创建简单代码(C#)，创建一个名为"myQueue"的非事务性"消息队列"，如下：　MessageQueue.Create(@".private$myQueue"); 二、创建、删除和管理队列　　在.NET环境下编写Message Queue程序的前提就是需要先安装MSMQ，本文之前已经作了详细的介绍。要开发MSMQ程序就必须学习一个很重要的类(MessageQueue)，该类位于名称空间System.Messageing下。其中有几个常用的方法必须掌握：　　--Create方法:创建使用指定路径的新消息队列。　　--Delete方法：删除现有的消息队列。　　--Existe方法：查看指定消息队列是否存在。　　--GetAllMessages()方法:得到队列中的所有消息。　　--GetPublicQueues方法：在“消息队列”网络中定位消息队列。　　--Peek/BeginPeek方法：查看某个特定队列中的消息队列，但不从该队列中移出消息。　　--Receive/BeginReceive方法：检索指定消息队列中最前面的消息并将其从该队列中移除。　　--Send方法：发送消息到指定的消息队列。　　--Purge方法：清空指定队列的消息。　　上述列举的方法在此就不作详细介绍，大家可以通过下面的示例程序中来体会他们各自的功能。三、发送和序列化消息　　MSMQ消息队列中定义的消息由一个主体(body)和若干属性构成。消息的主体可以由文本、二进制构成，根据需要还可以被加密。在MSMQ 中消息的大小不能够超过4MB。发送消息是通过Send方法来完成的，需要一个Message参数。　　1、发送消息：　　步骤：连接队列-->指定消息格式-->提供要发送的数据(主体)-->调用Send()方法将消息发送出去。详细见后面的示例程序。　　2、序列化消息：　　消息序列化可以通过.NET Framework附带的三个预定义格式化程序来完成：　　-- XMLMessageFormatter对象----MessageQueue组件的默认格式化程序设置。　　-- BinaryMessageFormatter对象;　　-- ActiveXMessageFormatter对象;　　由于后两者格式化后的消息通常不能为人阅读，所以我们经常用到的是XMLMessageFormatter对象。该对象构造方法有三种重载：　　 1public XmlMessageFormatter(); 　　2public XmlMessageFormatter(string[] targetTypeNames); 　　3public XmlMessageFormatter(Type[] targetTypes); 　　如我们后面的示例程序中用到的序列化语句：1//序列化为字符串 2XmlMessageFormatter formatter = new XmlMessageFormatter(new Type[] { typeof(string) });

有些应用程序需要非常高的吞吐量，而其他一些应用程序却正在发布批处理作业，这些作业可能会延迟一段时间。在设计系统时，目标应该是最大限度地将性能和可用性结合起来，这对您的特定应用程序是有意义的。错误的体系结构设计决策或客户端错误，可能会损坏中间件或影响吞吐量。 您的发布服务器可能会停止运行，或者由于内存使用过多而导致服务器崩溃。本系列文章重点关注rabbitmq的最佳实践。应做和不应做两种不同使用类别的最佳实践相混合;高可用性和高性能（高吞吐量）。我们将讨论队列大小、常见错误、延迟队列、预取值、连接和通道、HIPE和集群中的节点数。这些通常都是最佳实践规则，基于我们在使用rabbitmq时获得的经验。 队列中的许多消息会对RAM的使用造成很大的负担。为了释放RAM，rabbitmq将（页面输出）消息刷新到磁盘。此过程会降低排队速度。当有许多消息需要分页取出时，分页过程通常会花费时间并阻止队列处理消息。许多消息可能会对中间件的性能产生负面影响。 当有许多消息重启集群时，也是费时的，因为必须重建索引。重新启动后，在群集中的节点之间同步消息也需要时间。 在rabbitmq 3.6中添加了一个名为lazy queues的功能。懒惰队列是消息自动存储到磁盘上的队列。只有在需要时才将消息加载到内存中。对于懒惰的队列，消息直接进入磁盘，因此RAM的使用被最小化，但是吞吐时间将花费更长的时间。 我们已经看到，懒惰的队列以更好的可预测性的方式，创建了一个更稳定的集群。要让您的消息不出现警告，请刷新到磁盘。你不会突然被一个性能冲击问题所困扰。如果您一次发送大量消息（例如处理批处理作业），或者如果您认为您的消费者一直无法跟上发布者的速度，我们建议您启用延迟队列。 对于经常受到消息峰值冲击的应用程序，以及要求吞吐量比其他任何东西都重要的应用程序，可以推荐的另一做法是设置队列的最大长度。这样可以通过丢弃来自队列头部的消息来保持队列的简短性，从而使队列永远不会超过max-length设置。 队列在rabbitmq中是单线程的，一个队列可以处理大约50k条消息/秒。如果您有多个队列和消费者，您可以在多核系统上获得更好的吞吐量。如果在底层节点上拥有与核心一样多的队列，那么您将获得最佳吞吐量。 rabbitmq管理接口为集群中的每个队列收集和计算度量。如果您有数千个活动队列和使用者，这可能会减慢服务器的运行速度。如果队列太多，CPU和RAM的使用也可能受到负面影响。 队列性能受限于一个CPU核心。因此，如果将队列拆分到不同的核心，您将获得更好的性能；如果您拥有rabbitmq集群，您也可以将他们拆分到不同的节点。 rabbitmq队列绑定到最初声明它们的节点。即使您创建了一个rabbitmq中间件集群，所有路由到特定队列的消息都将转到该队列所在的节点。您可以在节点之间平均地手动拆分队列，但缺点是您需要记住队列的位置。 如果您有多个节点或具有多个核心的单节点集群，我们建议使用两个插件来帮助您: 当您想要在生产者和消费者之间共享队列时，为队列命名是很重要的，但是如果您使用临时队列，则不重要。相反，您应该让服务器使用一个随机的队列名称，而不是你自己命名一个——或者修改rabbitmq策略。 客户机连接可能会失败，并可能留下未使用的资源（队列），留下许多队列可能会影响性能。自动删除队列有三种方法: 在 Erlang VM 的内部队列每个队列均使用用了一个优先级别，他们耗费了一些资源。在大多数情况下，不超过5个优先级就足够了。 一个常见的问题是如何处理发送到rabbitmq的消息的palyload（消息大小）。当然，您不应该在消息中发送非常大的文件信息，但是每秒的消息数是一个比它本身的消息大小更大的瓶颈。发送多个小消息可能是一个坏的选择。一个更好的办法是将它们捆绑成一个更大的消息，让消费者将其拆分。但是，如果捆绑多条消息，则需要记住这可能会影响处理时间。如果其中一条捆绑消息失败，是否需要重新处理所有这些消息？如何设置这个取决于带宽和体系结构。 每个连接使用大约100kb的RAM（如果使用TLS，甚至更多）。数千个连接可能是rabbitmq服务器的沉重负担。在最坏的情况下，服务器可能由于内存不足而崩溃。AMQP协议有一种称为“多路复用”的机制，它“复用”单个TCP连接。它建议每个进程只创建一个TCP连接，并在这个唯一一个连接的基础上为不同的线程使用多个通道。连接也应该是长连接的。AMQP连接的握手过程非常复杂，至少需要7个TCP数据包（如果使用了TLS，则需要更多）。 相反，如果需要，可以更频繁地打开和关闭通道。如果可能的话，甚至通道也应该是长寿命的，例如，在每个发布信息线程中复用相同的通道。每次发布信息时不用打开频道。最佳实践是复用连接，使用各通道在一个连接的基础上实现多路复用。理想情况下，每个进程只能有一个连接，然后在应用程序中为每个线程使用一个通道，而每个channel 复用同一个连接即可。 您还应该确保不在线程之间共享通道，因为大多数客户机不保证通道是线程安全的（因为这样会对性能产生严重的负面影响）。 确保不要在线程之间共享通道，因为大多数客户机不会使通道线程安全（因为这样会对性能产生严重的负面影响）。 为发布者和消费者区分连接以获得高吞吐量。当发布服务器向服务器发送太多要处理的消息时，rabbitmq可以对TCP连接施加反向压力。如果消费者使用相同的TCP连接，服务器可能不会从客户机接收消息确认。因此，消费性能也会受到影响。而随着消费速度的降低，服务器将不堪重负。 具有大量连接和通道的另一个影响为rabbitmq管理接口的性能。对于每个连接和通道性能，指标必须收集、分析和显示度量。 在连接失败的情况下，传输中的消息可能会丢失，并且可能需要重新传输此类消息。Acknowledgements 让服务器和客户机知道何时重新传输消息。客户机可以在收到消息时对其进行确认，也可以在客户机完全处理完消息后对其进行确认。Acknowledgement 具有性能影响，因此为了实现最快的吞吐量，应该禁用手动确认。 接收重要消息的消费应用程序在完成需要对其进行的任何操作之前不应确认消息，这样未处理的消息（工作进程崩溃、异常等）就不会丢失。 发布确认，是相同的事情，但用于发布。服务器收到来自发布服务器的消息时会进行确认。发布确认也会影响性能。但是，应该记住，如果发布者至少需要处理一次消息，就需要这样做。 所有未确认的消息必须驻留在服务器上的RAM中。如果您有太多未确认的消息，您将耗尽内存。限制未确认消息的一个有效方法是客户端预取的消息数做出相关设置。在预取部分了解有关预取的更多信息。 如果您不能承受丢失任何消息的代价，请确保您的队列声明为“持久”，并且您的消息以传递模式“持久”发送。 为了避免在中间件中丢失消息，需要为中间件重新启动、中间件硬件故障或中间件崩溃时做好准备。为了确保消息和中间件定义在重新启动后仍然存在，我们需要确保它们在磁盘上。在中间件重新启动期间，不持久的消息、交换和队列将会被丢失。 持久性消息更重，因为它们必须写入磁盘。请记住，即使您发送的是临时消息，懒惰的队列也会对性能产生相同的影响。对于高性能-请使用瞬态消息。 您可以通过amqps连接到rabbitmq，这是用tls包装的amqp协议。由于所有流量都必须加密和解密，因此TLS会影响性能。为了获得最大的性能，我们建议使用vpc对等，那么流量是私有的，并且是独立的，不涉及AMQP客户机/服务器。 在cloudamqp中，我们将rabbitmq服务器配置为只接受快速但安全的加密密码并确定其优先级。 预取值用于指定多少条消息将同时被发送给消费者。它被用来从你的消费者那里得到尽可能多的东西(饱和工作)。 From RabbitMQ.com: “The goal is to keep the consumers saturated with work, but to minimise the client"s buffer size so that more messages stay in Rabbit"s queue and are thus available for new consumers or to just be sent out to consumers as they become free.” 来自rabbitmq.com：“我们的目标是让消费者饱和工作，但要最大限度地减小客户机的缓冲区大小，因此更多的消息被留在Rabbit的队列中，从而对新的消费者可用，或者发送给那些变得空闲的消者。” rabbitmq的默认预取设置为客户端提供了一个不受限制的缓冲区，这意味着rabbitmq在默认情况下会将尽可能多的消息发送给任何看起来准备接受它们的客户机。发送的消息由rabbitmq客户端库（在使用者中）缓存，直到对其进行处理。预取限制了在确认消息之前客户端可以接收的消息数。所有预取的消息都将从队列中删除，并且对其他使用者不可见。 A too small prefetch count may hurt performance since RabbitMQ is most of the time waiting to get permission to send more messages. The image below is illustrating long idling time. In the example, we have a QoS prefetch setting of 1. This means that RabbitMQ won"t send out the next message until after the round trip completes (deliver, process, acknowledge). Round time in this picture is in total 125ms with a processing time of only 5ms. 预取数太小可能会影响性能，因为rabbitmq大多数时间都在等待获得发送更多消息的许可。下图显示的是长时间的空转时间。在本例中，QoS预取设置为1。这意味着rabbitmq在往返完成（传递、处理、确认）之前不会发送下一条消息。图片中的整个周期时间总共为125ms，处理时间仅为5ms。 另一方面，大量的预取数可以接收队列中的大量消息并将其传递给同一个消费者，但是其他使用者却处于空闲状态。 如果您有一个或几个消费者快速处理消息，我们建议您一次预取多个消息。尽量让你的客户端繁忙。如果您一直有大约相同的处理时间，并且网络行为保持不变-您只需在客户机上为每个消息计算总的往返时间/处理时间，即可获得估计的预取值。 如果您有许多消费者，并且处理时间很短，我们建议预取值设置的应该比单个或少数使用者要低一些。太低的值会让消费者空转很多，因为他们需要等待消息到达。过高的值可能会使一个消费者忙碌，而其他消费者则处于空闲状态。 如果您有许多使用者和/或处理时间较长，我们建议您将预取计数设置为1，以便消息在所有消费者中均匀分布。 请注意，如果客户端自动确认消息，则预取值将不起作用。 一个典型的错误是有一个无限的预取，其中一个客户机接收所有的消息，耗尽内存并崩溃，然后所有的消息都被重新传递。 有关rabbitmq预取的信息，请参阅推荐的rabbitmq文档。 HIPE将以增加启动时间为代价增加服务器吞吐量。启用HIPE时，将在启动时编译rabbitmq。根据我们的基准测试，吞吐量增加了20-80%。HIPE的缺点是启动时间也增加了很多，大约1-3分钟。在rabbitmq的文档中，hipe仍然被标记为实验性的。 如果您需要高可用性，请不要启用HIPE。 当您用一个节点创建一个cloudamqp实例时，您将得到一个具有高性能的单个节点。一个节点将为您提供 最高的性能 ，因为消息不需要在多个节点之间进行镜像。 当您使用两个节点创建一个CloudAMQP实例时，与单个节点的相比，您将获得一半的性能。节点位于不同的可用性区域，队列在可用性区域之间自动镜像。两个节点将为您提供 高可用性 ，因为一个节点可能崩溃或被标记为受损，但另一个节点仍将启动并运行，准备接收消息。 当您使用三个节点创建一个CloudAMQP实例时，与单个节点的相同计划大小相比，您将获得1/4的性能。节点位于不同的可用性区域，队列在可用性区域之间自动镜像。您也可以暂停少数组件-与允许每个节点响应相比，通过关闭少数组件，您减少了重复传递。暂停少数组件是三节点集群中的一种分区处理策略，它可以防止由于网络拆分而导致数据不一致。 我们在cloudamqp集群中注意到的一个常见错误是，用户创建了一个新的vhost，但忘记为新的vhost启用一个ha策略。如果没有HA策略，则不会在节点之间同步消息。 直接交换是最快速。如果有许多bindings ，rabbitmq必须计算将消息发送到何处。 有些插件可能非常好用，但它们可能会消耗大量的CPU或RAM。因此，不建议将它们用于生产服务器。确保禁用不使用的插件。您可以通过CloudAmqp中的控制面板启用许多不同的插件。 将rabbitmq管理统计速率模式设置为detailed会严重影响性能，不应在生产中使用。 确保您使用的是最新推荐的客户端库版本 保持最新稳定版本的rabbitmq和erlang。在为客户发布新的主要版本之前，我们通常会在很大程度上对其进行测试。请注意，在为新集群选择版本的下拉列表中，我们始终使用最推荐的版本作为所选选项（默认）。 Dead lettering和TTL是rabbitmq中的两个流行功能，应该谨慎使用。TTL和Dead lettering可以产生您没有预料到的性能影响。 使用x-dead-letter-exchange属性声明的队列将向指定的dead-letter-exchange 发送被拒绝、非确认或过期（带有ttl）的消息。如果您指定了x-dead-letter-routing-key，则消息的路由键将在dead lettered时更改。 通过使用x-message-ttl属性声明队列，如果消息在指定的时间内未被使用，则将从队列中丢弃消息。

在Linux中,可以通过以下方式从消息队列MQ中读取报文信息:1. 使用自带的PN命令。如果使用的消息队列系统自带有消息查询命令,可以直接使用该命令查询消息队列中的报文。如RabbitMQ有rabbitmqctl list_queues等命令。2. 使用消息队列的API。大多数消息队列系统都提供了客户端API,可以通过编写程序使用 API 读取消息队列中的消息。例如:- RabbitMQ提供AMQP客户端API,可以使用Polyglot AMQP, librabbitmq等库调用API读取消息。- Kafka提供Kafka客户端API,可以使用kafka-python, librdkafka等库调用API读取主题中的消息。- ActiveMQ提供JMS API,可以使用JMS客户端如NMS读取消息。使用消息队列的API是主流的读取MQ报文的方式。需要选择消息队列对应的客户端API,编写读取消息的程序。3. 使用消息队列提供的管理工具。一些消息队列系统提供了图形化的管理控制台或工具,可以通过该工具查询和读取消息队列中的报文信息。如:- RabbitMQ提供了RabbitMQ Management插件,可以通过Web UI查询消息队列信息。- Kafka提供了Confluent Control Center等工具可以管理主题和消费消息。 - ActiveMQ提供了ActiveMQ Console可以管理消息和订阅者。使用管理工具可以更直观简便地读取MQ中的报文信息。4. 解析消息队列的数据存储。一些消息队列系统使用数据库等方式存储消息数据,通过解析其数据存储也可以读取报文信息。但这种方式较复杂,需要深入研究消息队列的内部实现,一般不推荐。所以,读取Linux下MQ的报文信息,推荐的方式主要是:1) 使用消息队列自带的命令行工具(如果有)2) 调用消息队列提供的API,编写程序读取消息3) 使用消息队列的管理控制台或图形化工具查询消息这几种方式可以比较方便和标准地读取MQ中的报文信息。选择具体的方式需要根据使用的消息队列系统来决定。

学习rabbitmq可以参考IT论坛,比如https://www.itkc8.com/forum/programme/2/699/1.html

在5.1.0之后可使用以下代码进行queues或topics队列获取.DestinationSource destinationSource = connection.getDestinationSource(); Set<ActiveMQQueue> queues = destinationSource.getQueues(); Set<ActiveMQTopic> topics = destinationSource.getTopics();

在5.1.0之后可使用以下代码进行queues或topics队列获取.DestinationSource destinationSource = connection.getDestinationSource(); Set<ActiveMQQueue> queues = destinationSource.getQueues(); Set<ActiveMQTopic> topics = destinationSource.getTopics();

之前的博客中我们可以在spring容器中构建 SimpleMessageListenerContainer 来消费消息，我们也可以使用 @RabbitListener 来消费消息。 定义消息处理器， @RabbitListener 注解标记的方法 应用启动类， @EnableRabbit 启用 @RabbitListener 测试： 控制台打印： 如果发送的消息 content_type 的属性是 text ，那么接收的消息处理方法的参数就必须是 String 类型，如果是 byte[] 类型就会报错。 控制台报错 总结 如果消息属性中没有指定 content_type ，则接收消息的处理方法接收类型是 byte[] ,如果消息属性中指定 content_type为text ，则接收消息的处理方法的参数类型是 String 类型。不管有没有指定 content_type ，处理消息方法的参数类型是Message都不会报错。 步骤 具体的消息处理方法的参数是跟 MessageConverter 转换后的java对象有关。 如果想要设置 MessageConverte r，则需要在 RabbitListenerContainerFactory 的实例中去设置，（ setMessageConverter 方法） 获取单一个Header的属性，Header还有其他的一些属性，比如 required ， defaultvalue 等属性，顾名思义： 配置文件： 启动类： 定义mq中不存在的 Queue ， exchange 和 route key 从上面的我们知道声明必须容器中要有 RabbitAdmin 和 RabbitTemplate 实例 应用启动类 测试验证 控制台打印： 说明自动声明的绑定中的队列被自动默认监听。 @RabbitListener 注解中的 bindings 和 queues 参数不能同时指定，否则会报错。 @RabbitListener 可以标注在类上面，当使用在类上面的时候，需要配合 @RabbitHandler 注解一起使用， @RabbitListener 标注在类上面表示当有收到消息的时候，就交给带有 @RabbitHandler 的方法处理，具体找哪个方法处理，需要跟进 MessageConverter 转换后的java对象。 配置： 处理器方法 应用启动类： 发送不包含content_type属性的消息和content_type属性为text的消息，控制台打印： @RabbitListener 注解的 containerFactory 属性可以指定一个 RabbitListenerContainerFactory 的bean，默认是找名字为 rabbitListenerContainerFactory 的实例。 当我们将 ConsumerConfig 类中的 RabbitListenerContainerFactory 实例的对象名改掉的时候，发现就会报错。 此时控制台上报错， 此时如果配置一下 @RabbitListener 注解的 containerFactory 属性便不会报错。 我们再去改造一下在 RabbitListenerContainerFactory 实例中定义消息类型转换器 User对象： 在处理器中增加参数是User的方法：

在5.1.0之后可使用以下代码进行queues或topics队列获取.DestinationSource destinationSource = connection.getDestinationSource(); Set<ActiveMQQueue> queues = destinationSource.getQueues(); Set<ActiveMQTopic> topics = destinationSource.getTopics()

AMQP(高级消息队列协议) 是一个异步消息传递所使用的应用层协议规范，作为线路层协议，而不是API（例如JMS），AMQP 客户端能够无视消息的来源任意发送和接受信息。AMQP的原始用途只是为金融界提供一个可以彼此协作的消息协议，而现在的目标则是为通用消息队列架构提供通用构建工具。因此，面向消息的中间件 （MOM）系统，例如发布/订阅队列，没有作为基本元素实现。反而通过发送简化的AMQ实体，用户被赋予了构建例如这些实体的能力。这些实体也是规范的一 部分，形成了在线路层协议顶端的一个层级：AMQP模型。这个模型统一了消息模式，诸如之前提到的发布/订阅，队列，事务以及流数据，并且添加了额外的特性，例如更易于扩展，基于内容的路由。AMQP当中有四个概念非常重要virtual host，虚拟主机exchange，交换机queue，队列binding，绑定一个虚拟主机持有一组交换机、队列和绑定。为什么需要多个虚拟主机呢？因为RabbitMQ当中，用户只能在虚拟主机的粒度进行权限控制。因此，如果需要禁止A组访问B组的交换机/队列/绑定，必须为A和B分别创建一个虚拟主机。每一个RabbitMQ服务器都有一个默认的虚拟主机/。何谓虚拟主机（virtual host），交换机（exchange），队列（queue）和绑定（binding）队列（Queues）是你的消息（messages）的终点，可以理解成装消息的容器。消息就一直在里面，直到有客户端（也就是消费者，Consumer）连接到这个队列并且将其取走为止。不过，也可以将一个队列配置成这样的：一旦消息进入这个队列，此消息就被删除。队列是由消费者（Consumer）通过程序建立的，不是通过配置文件或者命令行工具。这没什么问题，如果一个消费者试图创建一个已经存在的队列，RabbitMQ会直接忽略这个请求。因此我们可以将消息队列的配置写在应用程序的代码里面。而要把一个消息放进队列前，需要有一个交换机（Exchange）。交换机（Exchange）可以理解成具有路由表的路由程序。每个消息都有一个称为路由键（routing key）的属性，就是一个简单的字符串。交换机当中有一系列的绑定（binding），即路由规则（routes）。（例如，指明具有路由键 “X” 的消息要到名为timbuku的队列当中去。）消费者程序（Consumer）要负责创建你的交换机。交换机可以存在多个，每个交换机在自己独立的进程当中执行，因此增加多个交换机就是增加多个进程，可以充分利用服务器上的CPU核以便达到更高的效率。例如，在一个8核的服务器上，可以创建5个交换机来用5个核，另外3个核留下来做消息处理。类似的，在RabbitMQ的集群当中，你可以用类似的思路来扩展交换机一边获取更高的吞吐量。交换机如何判断要把消息送到哪个队列？你需要路由规则，即绑定（binding）。一个绑定就是一个类似这样的规则：将交换机“desert（沙漠）”当中具有路由键“阿里巴巴”的消息送到队列“hideout（山洞）”里面去。换句话说，一个绑定就是一个基于路由键将交换机和队列连接起来的路由规则。例如，具有路由键“audit”的消息需要被送到两个队列，“log-forever”和“alert-the-big-dude”。要做到这个，就需要创建两个绑定，每个都连接一个交换机和一个队列，两者都是由“audit”路由键触发。在这种情况下，交换机会复制一份消息并且把它们分别发送到两个队列当中。交换机不过就是一个由绑定构成的路由表。交换机有多种类型。他们都是做路由的，但是它们接受不同类型的绑定。为什么不创建一种交换机来处理所有类型的路由规则呢？因为每种规则用来做匹配分子的CPU开销是不同的。例如，一个“topic”类型的交换机试图将消息的路由键与类似“dogs.*”的模式进行匹配。匹配这种末端的通配符比直接将路由键与“dogs”比较（“direct”类型的交换机）要消耗更多的CPU。如果你不需要“topic”类型的交换机带来的灵活性，你可以通过使用“direct”类型的交换机获取更高的处理效率。

M 代表标准电压cpu是可以拆卸的u 代表低电压节能的，可以拆卸的H是高电压的，是焊接的，不能拆卸x 代表高性能Q代表至高 性能级别。Y代表超低电压的，除了省电，没别的优点的了，是不能拆卸的。

不是

hmqbq.dll 不是系统文件考虑是病毒伪装或者其他软件程序

第一个是Intel台式机处理器的后缀，而后三个是笔记本处理器的后缀。具体的意思是：1.带K代表不锁倍频，可以任意超频；2.带MQ代表PGA封装四核处理器，可以更换；3.带HQ代表BGA封装四核处理器，不可以更换，而且TDP要比同级的MQ高一些；4.带U代表低压版，功耗和性能都大幅低于正常版处理器。CPU包括运算逻辑部件、寄存器部件和控制部件等,英文Logic components;运算逻辑部件，可以执行定点或浮点算术运算操作、移位操作以及逻辑操作，也可执行地址运算和转换。

是正品

你这是需要村田的IC吧！交期多久啊？不清楚你公司在哪里！我有朋友可能会有，不过我们在苏州，配合起来可能会不太方便！我的MSN：hupeng1986-2009@hotmail.com.

牌子是murata,型号是MQC309是电子元件murata其实就是村田，全称是株式会社村田制作所，是日本知名电子元器件生产厂家，苏州芯特微电子科技有限公司代理村田全系列产品，主要产品包括电容器、电阻器、电感器（线圈）、静噪元件、滤波器、振荡子、压电声音原件高频元件、传感器等。村田产品广泛应用汽车电子、通讯设施、仪器仪表、电子设备、高端无线产品、开关电源、视听产品、家用电器等电子领域。资料扩展该公司于1944年10月创业，1950年12月正式改名为村田制作所。创业者是村田昭主力商品是陶瓷电容器，高居世界首位。其他具领导地位的零件产品计有陶瓷滤波器，高频零件，感应器等。村田制作所是全球领先的电子元器件制造商。村田制作所的客户分布在PC、手机、汽车电子等领域。随着消费电子领域竞争的不断加剧，产品更新换代的速度不断加快，而作为上游电子元器件供应商，能够随时了解客户需求，甚至走在客户之前开发出更新产品，成为村田制作所业务持续增长的关键。不断推出新产品是村田制作所的竞争力源泉，而不断推出市场需要的产品则是其业绩保持增长的保障。

（1）证明：过点M作MG⊥BC于点G，MH⊥CD于点H．∴∠MGE=∠MHF=90°．∵M为正方形对角线AC、BD的交点，∴MG=MH．又∵∠1+∠GMQ=∠2+∠GMQ=90°，∴∠1=∠2．在△MGE和△MHF中∠1=∠2，MG=MH，∠MGE=∠MHF．∴△MGE≌△MHF．∴ME=MF．（3分）（2）解：①当MN交BC于点E，MQ交CD于点F时．过点M作MG⊥BC于点G，MH⊥CD于点H．∴∠MGE=∠MHF=90°．∵M为矩形对角线AC、BD的交点，∴∠1+∠GMQ=∠2+∠GMQ=90°．∴∠1=∠2．在△MGE和△MHF中，∠1=∠2∠MGE=∠MHF∴△MGE∽△MHF．∴MEMF＝MGMH．∵M为矩形对角线AB、AC的交点，∴MB=MD=MC又∵MG⊥BC，MH⊥CD，∴点G、H分别是BC、DC的中点．∵BC=2AB=4，∴MG＝12AB，MH＝12BC．∴MEMF＝12．（4分）②当MN的延长线交AB于点E，MQ交BC于点F时．过点M作MG⊥AB于点G，MH⊥BC于点H．∴∠MGE=∠MHF=90°．∵M为矩形对角线AC、BD的交点，∴∠1+∠GMQ=∠2+∠GMQ=90°．∴∠1=∠2．在△MGE和△MHF中，∠1=∠2，∠MGE=∠MHF．∴△MGE∽△MHF．∴MEMF＝MGMH．∵M为矩形对角线AC、BD的交点，∴MB=MA=MC．又∵MG⊥AB，MH⊥BC，∴点G、H分别是AB、BC的中点．∵BC=2AB=4，∴MG＝12BC，MH＝12AB．∴MEMF＝2．（5分）③当MN、MQ两边都交边BC于E、F时．过点M作MH⊥BC于点H．∴∠MHE=∠MHF=∠NMQ=90°．∴∠1=∠3，∠2=∠4．∴△MEH∽△FEM，△FMH∽△FEM．∴MEFE＝MHFM，FMFE＝MHEM．∵M为矩形对角线AC、BD的交点，∴点M为AC的中点．又∵MH⊥BC，∴点M、H分别是AC、BC的中点．∵BC=2AB=4，∴AB=2．∴MH=1．∴1ME＝FMMH?EF＝FMEF，1MF＝EMMH?EF＝EMEF．∴1ME2+1MF2＝FM2+EM2EF2＝1．（6分）④当MN交BC边于E点，MQ交AD于点F时．延长FM交BC于点G．易证△MFD≌△MGB．∴MF=MG．同理由③得

RocketMQ的事务消息，是指发送消息事件和其他事件需要同时成功或同时失败。比如银行转账，A银行的某账户要转一万元到B银行的某账户。A银行发送“B银行账户增加一万元”这个消息，要和“从A银行账户扣除一万元”这个操作同时成功或者同时失败。 RocketMQ采用两阶段提交的方式实现事务消息，TransactionMQProducer处理上面情况的流程是，先发一个“准备从B银行账户增加一万元”的消息，发送成功后做从A银行账户扣除一万元的操作，根据操作结果是否成功，确定之前的“准备从B银行账户增加一万元”的消息是做commit还是rollback，具体流程如下： 1）发送方向RocketMQ发送“待确认”消息。 2）RocketMQ将收到的“待确认”消息持久化成功后，向发送方回复消息已经发送成功，此时第一阶段消息发送完成。 3）发送方开始执行本地事件逻辑。 4）发送方根据本地事件执行结果向RocketMQ发送二次确认（Commit或是Rollback）消息，RocketMQ收到Commit状态则将第一阶段消息标记为可投递，订阅方将能够收到该消息；收到Rollback状态则删除第一阶段的消息，订阅方接收不到该消息。 5）如果出现异常情况，步骤4）提交的二次确认最终未到达RocketMQ，服务器在经过固定时间段后将对“待确认”消息发起回查请求。 6）发送方收到消息回查请求后（如果发送一阶段消息的Producer不能工作，回查请求将被发送到和Producer在同一个Group里的其他Producer），通过检查对应消息的本地事件执行结果返回Commit或Roolback状态。 7）RocketMQ收到回查请求后，按照步骤4）的逻辑处理。 上面的逻辑似乎很好地实现了事务消息功能，它也是RocketMQ之前的版本实现事务消息的逻辑。 但是因为RocketMQ依赖将数据顺序写到磁盘这个特征来提高性能，步骤4）却需要更改第一阶段消息的状态，这样会造成磁盘Catch的脏页过多，降低系统的性能。所以RocketMQ在4.x的版本中将这部分功能去除。系统中的一些上层Class都还在，用户可以根据实际需求实现自己的事务功能。 客户端有三个类来支持用户实现事务消息， 第一个类是LocalTransaction-Executer，用来实例化步骤3）的逻辑，根据情况返回LocalTransactionState.ROLLBACK_MESSAGE或者 LocalTransactionState.COMMIT_MESSAGE状态。 第二个类是TransactionMQProducer，它的用法和DefaultMQProducer类似，要通过它启动一个Producer并发消息，但是比DefaultMQProducer多设置本地事务处理函数和回查状态函数。 第三个类是TransactionCheckListener，实现步骤5）中MQ服务器的回查请求，返回LocalTransactionState.ROLLBACK_MESSAGE或者LocalTransactionState.COMMIT_MESSAGE 上图说明了事务消息的大致方案，其中分为两个流程：正常事务消息的发送及提交、事务消息的补偿流程。 1.事务消息发送及提交： (1) 发送消息（half消息）。 (2) 服务端响应消息写入结果。 (3) 根据发送结果执行本地事务（如果写入失败，此时half消息对业务不可见，本地逻辑不执行）。 (4) 根据本地事务状态执行Commit或者Rollback（Commit操作生成消息索引，消息对消费者可见）。 2.补偿流程： (1) 对没有Commit/Rollback的事务消息（pending状态的消息），从服务端发起一次“回查”。 (2) Producer收到回查消息，检查回查消息对应的本地事务的状态。 (3) 根据本地事务状态，重新Commit或者Rollback。 其中，补偿阶段用于解决消息Commit或者Rollback发生超时或者失败的情况。 在RocketMQ事务消息的主要流程中，一阶段的消息如何对用户不可见。其中，事务消息相对普通消息最大的特点就是一阶段发送的消息对用户是不可见的。那么，如何做到写入消息但是对用户不可见呢？RocketMQ事务消息的做法是：如果消息是half消息，将备份原消息的主题与消息消费队列，然后改变主题为RMQ_SYS_TRANS_HALF_TOPIC。由于消费组未订阅该主题，故消费端无法消费half类型的消息。然后二阶段会显示执行提交或者回滚half消息（逻辑删除）。当然，为了防止二阶段操作失败，RocketMQ会开启一个定时任务，从Topic为RMQ_SYS_TRANS_HALF_TOPIC中拉取消息进行消费，根据生产者组获取一个服务提供者发送回查事务状态请求，根据事务状态来决定是提交或回滚消息。 在RocketMQ中，消息在服务端的存储结构如下，每条消息都会有对应的索引信息，Consumer通 过ConsumeQueue这个二级索引来读取消息实体内容，其流程如下： RocketMQ的具体实现策略是：写入的如果事务消息，对消息的Topic和Queue等属性进行替换，同时将原来的Topic和Queue信息存储到消息的属性中，正因为消息主题被替换，故消息并不会转发到该原主题的消息消费队列，消费者无法感知消息的存在，不会消费。其实改变消息主题是RocketMQ的常用“套路”，回想一下延时消息的实现机制。RMQ_SYS_TRANS_HALF_TOPIC 在完成一阶段写入一条对用户不可见的消息后，二阶段如果是Commit操作，则需要让消息对用户可见；如果是Rollback则需要撤销一阶段的消息。先说Rollback的情况。对于Rollback，本身一阶段的消息对用户是不可见的，其实不需要真正撤销消息（实际上RocketMQ也无法去真正的删除一条消息，因为是顺序写文件的）。但是区别于这条消息没有确定状态（Pending状态，事务悬而未决），需要一个操作来标识这条消息的最终状态。RocketMQ事务消息方案中引入了Op消息的概念，用Op消息标识事务消息已经确定的状态（Commit或者Rollback）。如果一条事务消息没有对应的Op消息，说明这个事务的状态还无法确定（可能是二阶段失败了）。引入Op消息后，事务消息无论是Commit或者Rollback都会记录一个Op操作。Commit相对于Rollback只是在写入Op消息前创建Half消息的索引。 RocketMQ将Op消息写入到全局一个特定的Topic中通过源码中的方法— TransactionalMessageUtil.buildOpTopic()；这个Topic是一个内部的Topic（像Half消息的Topic一样），不会被用户消费。Op消息的内容为对应的Half消息的存储的Offset，这样通过Op消息能索引到Half消息进行后续的回查操作。 在执行二阶段Commit操作时，需要构建出Half消息的索引。一阶段的Half消息由于是写到一个特殊的Topic，所以二阶段构建索引时需要读取出Half消息，并将Topic和Queue替换成真正的目标的Topic和Queue，之后通过一次普通消息的写入操作来生成一条对用户可见的消息。所以RocketMQ事务消息二阶段其实是利用了一阶段存储的消息的内容，在二阶段时恢复出一条完整的普通消息，然后走一遍消息写入流程。 如果在RocketMQ事务消息的二阶段过程中失败了，例如在做Commit操作时，出现网络问题导致Commit失败，那么需要通过一定的策略使这条消息最终被Commit。RocketMQ采用了一种补偿机制，称为“回查”。Broker端对未确定状态的消息发起回查，将消息发送到对应的Producer端（同一个Group的Producer），由Producer根据消息来检查本地事务的状态，进而执行Commit或者Rollback。 Broker端通过对比Half消息和Op消息进行事务消息的回查并且推进CheckPoint（记录那些事务消息的状态是确定的）。 值得注意的是，rocketmq并不会无休止的的信息事务状态回查，默认回查15次，如果15次回查还是无法得知事务状态，rocketmq默认回滚该消息。 TxConsumer类实现

Cras numquam scire（feat.Hugh Anthony Disward） 　　 　　演唱Yucca，作曲辻阳，歌名大意可以理解成“未来を见た者はいないと”（永远未知明天） 　　个人另推荐OP的纯音乐版，手风琴音色更符合原作的世界观感。 　　 　　 　　Lune oqui cr pos tatumn. 　　Homu aude cr dis Soenan. 　　Cure Tint le vid siesta. 　　Mimo scap ler nox grad. 　　Astr scrib cr pos arcan. 　　Homu scire cr dis Abesn. 　　Infor Sintac le tabu vern. 　　Gigan Leinau le nascour. 　　Cae lie imam plati nor main. 　　Tempo le imam celer or mint. 　　Nihil dis scio leo rina nis. 　　Colle Sintac mi 　　Sina cader plutien. 　　Igo clama re nihil minus. 　　Dis sciren ex Soenan. 　　Conti affir mia Celest. 　　Nova Sol ie rad four. 　　 　　月は静かに语る 　　だれにも聴こえぬ声で 　　缲り返す潮の満ち引き 　　消えゆく记忆の情景 　　星は密かに记す 　　だれにも解らぬ文字で 　　无限の言叶が涡巻き 　　千亿の本が产まれた 　　仆には空が広すぎて 　　时の刻みは速すぎて 　　何も知らぬまま虚しく 　　集めた言叶も 　　土の中に朽ちるだけ 　　それでも仆は叫ぶ 　　わけも解らず声を上げる 　　せめて响きは天にとどけ 　　日もやがて升るだろう 　　 　　卑屈な闇が答えた 　　未来を见た者はいないと 　　仆は虚空に手をのばし 　　冷たい风をつかむ 　　绝望よ吹き抜けろ！ 　　梦も苦悩もすべて过去へ 　　地上はまどろむ薄明の中 　　仆は前に进む 　　まだ见ぬ明日へ 　　 　　 　　月亮默默低语着 　　诉说以轻不可闻声音 　　周而复始的潮起潮落 　　唯有记忆中的风景逐渐斑驳消散 　　星辰悄悄记述着 　　书写以无人知晓的文字 　　无数的篇章掀起波澜 　　令千亿册书籍降临人间 　　我所身处的世界太过广袤 　　时光前行的脚步也过于匆忙 　　就这样无知而空虚地度过短暂人生 　　汇集而来的那些篇章 　　也只得于泥土中腐朽消散 　　即便如此我也要竭声呼喊 　　不明缘由地想将声音传达到苍穹之上 　　即使只有余音回响于天际 　　黎明也终究会降临于此吧 　　卑屈的暗夜回答我 　　「无人可以预知未来」 　　我向着虚空竭力而徒劳地伸出手去 　　所抓住的　不过是冰冷的微风一缕 　　绝望啊　来掀起狂岚吧！ 　　梦想也好苦恼也罢　将一切都送归往昔 　　于人间浅眠的曙光中 　　我开始前行 　　向着仍未可知的明天 　　 　　 　　tsuki ha shizuka ni kataru 　　darenimo kiko enu koe de 　　kurikaesu shio no michi hiki 　　kie yuku kioku no joukei 　　hoshi ha hisoka ni shirusu 　　darenimo wakara nu moji de 　　mugen no kotoba ga uzumaki 　　sen oku no hon ga uma reta 　　boku niha sora ga hirosu gite 　　tokino kizami ha hayasu gite 　　nanimo shira numama munashi ku 　　atsume ta kotoba mo 　　tsuchi no nakani kuchi rudake 　　soredemo bokuha sakebu 　　wakemo wakara zu koe wo age ru 　　semete hibiki ha ten nitodoke 　　hi moyagate noboru darou 　　hikutsu na yami ga kotae ta 　　mirai wo mita mono hainaito 　　bokuha kyokuu ni te wonobashi 　　tsumeta i kaze wotsukamu 　　zetsubou yo fukinuke ro ! 　　yume mo kunou mosubete kako he 　　chijou hamadoromu haku mei no naka 　　bokuha mae ni susumu 　　mada minu ashita he

月（つき）は静（しず）かに语（かた）るだれにも聴（き)こえね声(こえ）で缲（くり）り返（かえ）す潮（しお）の満（み）ち引（ひ）き消（き）えゆく记忆（きおく）の情景（じょうけい)星（ほし）は密（ひそ）かに记（しる）すだれにも解（わか）らぬ文字（もじ）で无限（むげん）の言叶（ことば）涡巻（うずま）き千亿（せんおく）の本（ほん）产（う）まれた仆（ぼう）には空（そら）が広（ひろ）すぎて时（とき）の刻（きざ）みは速（はや）すぎて何（なに）も知（し）らぬまま虚（むな）しく集（あつ）めた言叶（ことば）も土（つち）の中（なか）に朽（く）ちるだけそれでも仆（ぼく）は叫（さけ）ぶわけも解（わか）らず声（こえ）を上（あ）げるせめえ（响（ひび）きは天（てん）にとどけ日（ひ）もやがて升（のぼ）るだろう卑屈（ひくつ）な暗（やみ）が答（こた）えた未来（みらい）を见（み）た者（もの）はいないと仆（ぼく）は虚空（こくう）に手（て）をのばし冷（つね）たい风（かぜ）をつかむ绝望（ぜつぼう）よ吹（ふ）く抜（ぬ）けろ！梦（ゆめ）も苦悩（くのう）もすべて过去（かこ）へ地上（じじょう）はもどろむ薄明（はくめい）の中（なか）仆（ぼく）は前（まえ）に进（すす）むまだ见（み）ぬ明日（あした）へ终わり-月亮默默低语着 诉说以轻不可闻声音 周而复始的潮起潮落 唯有记忆中的风景逐渐斑驳消散 星辰悄悄记述着 书写以无人知晓的文字 无数的篇章掀起波澜 令千亿册书籍降临人间 我所身处的世界太过广袤 时光前行的脚步也过于匆忙 就这样无知而空虚地度过短暂人生 汇集而来的那些篇章 也只得于泥土中腐朽消散 即便如此我也要竭声呼喊 不明缘由地想将声音传达到苍穹之上 即使只有余音回响于天际 黎明也终究会降临于此吧 卑屈的暗夜回答我 「无人可以预知未来」 我向着虚空竭力而徒劳地伸出手去 所抓住的　不过是冰冷的微风一缕 绝望啊　来掀起狂岚吧！ 梦想也好苦恼也罢　将一切都送归往昔 于人间浅眠的曙光中 我开始前行 向着仍未可知的明天 **罗马音Lune oqui cr pos tatumn.Homu aude cr dis Soenan.Cure Tint le vid siesta.Mimo Scap ler nox grad.Astr scrib cr pos arcan.Homu scire cr dis Abesn.Infor Sintac le tabu vern.Gigan Leinau le nascour.Cae lie imam plati nor main.Tempo le imam celer or mint.Nihil dis scio Igo rina nis.Colle Sintac miSina cader plutien.Igo clama re nihil minus.Dis sciren ex Soenan.Conti affir mia Celest.Nova Sol ie rad four.tsuki ha shizukani katarudare ni mo kikoenu koe dekurikaesu shio no michi hikikieyuku kioku no joukeihoshi ha hisoka ni shirusudare ni mo wakaranu moji demugen no kotoba ga uzumakisen oku no hon ga umaretaboku ni ha sora ga hiro sugitetoki no kizami ha haya sugitenani mo shiranumama munashikuatsumeta kotoba motsuchi no naka ni kuchiru dakesoredemo boku ha sakebuwake mo wakarazu koe wo agerusemete hibiki ha ten ni todokehi mo yagate noboru darouhikutsu na yami ga kotaetamirai wo mita mono ha inai toboku ha kyokuu ni te wo nobashitsumetai kaze wo tsukamuzetsubou yo fuki nukero!yume mo kunou mo subete kako hechijou ha madoromu hakumei no nakaboku ha mae ni susumumada minu ashita he

[00:00.00]Cras numquam scire[00:04.00]TVアニメ「ダンタリアンの书架」OPテーマ[00:08.00]作词：ノリクスu30fbベネディクトゥス[00:12.00]作曲：辻阳[00:16.00]编曲：辻阳[00:20.00]歌：Yucca feat.Hugh Anthony Disward(小野大辅)[00:24.00][00:26.26]Lune oqui cr pos tatumn.[00:31.17]Homu aude cr dis Soenan.[00:35.74]Cure Tint le vid siesta.[00:40.72]Mimo scap ler nox grad.[00:45.69][00:46.03]Astr scrib cr pos arcan.[00:50.61]Homu scire cr dis Abesn.[00:55.29]Infor Sintac le tabu vern.[01:00.48]Gigan Leinau le nascour.[01:07.35][01:07.96]Cae lie imam plati nor main.[01:12.62]Tempo le imam celer or mint.[01:18.07]Nihil dis scio leo rina nis.[01:22.71]Colle Sintac mi[01:25.18]Sina cader plutien.[01:32.09][01:32.53]Igo clama re nihil minus.[01:37.32]Dis sciren ex Soenan.[01:42.26]Conti affir mia Celest.[01:47.21]Nova Sol ie rad four.[01:55.37][02:33.45][02:35.45]月は静かに语る【在月下轻轻的私语】[02:38.34]だれにも聴こえぬ声で【聆听无人能听见的声音】[02:42.35]缲り返す潮の満ち引き【重复起落的潮水】[02:45.43]消えゆく记忆の情景【已经褪色的记忆场景】[02:47.96][02:49.69]星は密かに记す【被星痕偷偷记录】[02:52.61]だれにも解らぬ文字で【无人能解读的文字】[02:55.00]无限の言叶が涡巻き【无限的言语螺旋】[02:57.76]千亿の本が产まれた【构筑了千亿本的书籍】[02:59.98][03:01.12]仆には空が広すぎて【我在广阔的天空中】[03:04.54]时の刻みは速すぎて【任凭时间飞速的流逝】[03:07.83]何も知らぬまま虚しく【只有无知的空虚】[03:10.91]集めた言叶も【只要是言语的集结】[03:13.42]土の中に朽ちるだけ【定会在土地中腐烂】[03:15.34][03:16.49]それでも仆は叫ぶ【但是我可以呐喊】[03:19.45]わけも解らず声を上げる【不知道喊音能到多高】[03:22.97]せめて响きは天にとどけ【但至少能响彻在广阔的天空中】[03:26.20]日もやがて升るだろう【传达到最终太阳升起的地方】[03:28.58][03:30.87]卑屈な闇が答えた【卑屈的黑暗回答我】[03:33.64]未来を见た者はいないと【无人能目睹未来】[03:36.45]仆は虚空に手をのばし【我对着虚空无力的伸出手】[03:39.58]冷たい风をつかむ【抓住的只有冰冷的风】[03:41.76][03:42.90]绝望よ吹き抜けろ！【绝望哟 扫平一切吧】[03:45.26]梦も苦悩もすべて过去へ【梦想并着绝望 一切归附过往】　[03:49.42]地上はまどろむ薄明の中【地界微明的晨光中】[03:52.59]仆は前に进む【我向前行进】[03:55.81]まだ见ぬ明日へ【朝着仍然未明的明日】[03:57.85][04:00.00]终わり

以下是Cras numquam scire《丹特丽安的书架》主题曲的歌词：Salve, libro sancto, laus et honor,欢迎，神圣的书籍，赞美与荣耀dedicato tuo, quicumque venerandrum不论何人，皆须致敬scriptorumque pectora, verum in omnibus作家之心，真实尽在其中magnarum rerum, quae transmutare potest伟大的事物，能改变一切nec scire tua voluntas, quamvis ignoremus你的意愿，我们虽不知sed tua, quamquam ignota, scientia laboret你的知识，虽然未知，却会受困于知识nunc autem hoc corpus, quo libro vere eras现在，你所守护的，这本书的真相opus magnum erit, tota res eius magna这部作品将成为伟大的事物，整体都非常重要quo transmutare manus tua, quo solacium daremus我们将用我们的双手改变它，给予它慰藉haec pagina nostra, haec vita nostra est这一页，就是我们的生活，就是我们的生命

刷prema的mod

（转帖）盘点人生十商（IQ,EQ,MQ,FQ,HQ,WQ,AQ,DQ,SQ) 成功是每一个人都梦想，可成功不是从天上掉下来的，而是通过不断的修炼、积累而获得，只要努力提高“十商”智慧和能力，追求全面、均衡发展，您也一定能够构建成功而幸福的大厦。　　　1. 德商（MQ）　　德商（Moral Intelligence Quotient，缩写成MQ），是指一个人的德性水平或道德人格品质。德商的内容包括体贴、尊重、容忍、宽恕、诚实、负责、平和、忠心、礼貌、幽默等各种美德。我们常说的“德智体”中是把德放在首位的；科尔斯说，品格胜于知识。可见，德是最重要的。一个有高德商的人，一定会受到信任和尊敬，自然会有更多成功的机会。　　古人云：“得道多助，失道寡助”、“道之以德，德者得也”，就是告诉我们要以道德来规范自己的行为，不断修炼自己，才能获得人生的成功。古今中外，一切真正的成功者，在道德上大都达到了很高的水平。　　现实中的大量事实说明，很多人的失败，不是能力的失败，而是做人的失败、道德的失败。　　2. 智商（IQ）　　智商（Intelligence Quotient，缩写成IQ）是一种表示人的智力高低的数量指标，但也可以表现为一个人对知识的掌握程度，反映人的观察力、记忆力、思维力、想像力、创造力以及分析问题和解决问题的能力。确实，智商不是固定不变的，通过学习和训练是可以开发增长的。我们要走向成功，就必须不断学习，积累智商。　　我们不仅要从书本、从社会学习，还要从我们的上司那里学习。因为你的上司今天能有资格当你的上司，肯定有比你厉害的地方，有很多地方值得你去学习。很多人都想超越他的上司，这是非常可贵的精神，但要超越你的老板，你不学习他成功的地方，何谈超越？不断地学习，提高智商，这是成功的基本条件。　　3. 情商（EQ）　　情商（Emotional Intelligence Quotient，简写成EQ），就是管理自己的情绪和处理人际关系的能力。如今，人们面对的是快节奏的生活，高负荷的工作和复杂的人际关系，没有较高的EQ是难以获得成功的。EQ高的人，人们都喜欢同他交往，总是能得到众多人的拥护和支持。同时，人际关系也是人生重要资源，良好的人际关系往往能获得更多的成功机会。权变理论代表人物之一弗雷德·卢森斯（Fred Luthans）对成功的管理者（晋升速度快）与有效的管理者（管理绩效高）做过调查，发现两者显著不同之处在于：维护人际网络关系对成功的管理者贡献最大，占48％，而对有效的管理者只占11％。可见，在职场中，要获得较快的成长，仅仅埋头工作是不够的，良好的人际关系是获得成功的重要因素。　　4. 逆商（AQ）　　逆商(Adversity Intelligence Quotient，简写成AQ)，是指面对逆境承受压力的能力，或承受失败和挫折的能力。当今和平年代，应付逆境的能力更能使你立于不败之地。“苦难对于天才是一块垫脚石，对于能干的人是一笔财富，而对于弱者则是一个万丈深渊。”“苦难是人生最好的教育。”名人之谈告诉我们：伟大的人格只有经历熔炼和磨难，潜力才会激发，视野才会开阔，灵魂才会升华，才会走向成功，正所谓吃得苦中苦，方为人上人。　　任何国家和地区的富豪，约八成出身贫寒或学历较低，他们白手起家创大业，赢得了令人羡慕的财富和名誉。他们没有一个是一帆风顺，甚至大起大落，几经沉浮，不经失败和挫折就获得成功的。　　逆境不会长久，强者必然胜利。因为人有着惊人的潜力，只要立志发挥它，就一定能渡过难关，成就生命的辉煌。　　5. 胆商（DQ）　　胆商（Daring Intelligence Quotient，缩写成DQ）是一个人胆量、胆识、胆略的度量，体现了一种冒险精神。胆商高的人能够把握机会，该出手时就出手。无论是什么时代，没有敢于承担风险的胆略，任何时候都成不了气候。而大凡成功的商人、政客，都是具有非凡胆略和魄力的。　　6. 财商（FQ）　　财商（Financial Intelligence Quotient，简写成FQ），是指理财能力，特别是投资收益能力。没有理财的本领，你有多少钱也会慢慢花光的，所谓“富不过三代”就是指有财商的老子辛辛苦苦积攒下来的钱，最多最后也会败在无财商的子孙手中。财商是一个人最需要的能力，也是最被人们忽略的能力。　　我们的父辈都是“穷爸爸”，只教我们好好读书，找好工作，多存钱，少花钱。赚得少一点没关系，关键是稳定。他们从没教过我要有财商，要考虑怎么理财。所以，财商对我们来说是迫切需要培养的一种能力。会理财的人越来越富有，一个关键的原因就是财商区别。特别是富人，何以能在一生中积累如此巨大的财富？答案是：投资理财的能力。　　7. 心商（MQ）　　心商（Mental Intelligence Quotient，简写成MQ），就是维持心理健康，调试心理压力，保持良好心理状况和活力的能力。21世纪是“抑郁时代”，人类面临更大的心理压力，提高心商，保持心理健康已成为时代的迫切需要。现代人渴望成功，而成功越来越取决于一个人的心理状态，取决于一个人的心理健康。从某种意义上来讲，心商的高低，直接决定了人生过程的苦乐，主宰人生命运的成败。　　世上有很多人，取得了很大的成功，可因承受着生活的各种压力，郁郁寡欢，因不堪重压或经不起生命的一次挫折患上心理障碍，甚至走上不归路，演绎一幕幕人间悲剧。　　8. 志商（WQ）　　“志商”就是意志智商（Will Intelligence Quotient，简写成WQ ），指一个人的意志品质水平，包括坚韧性、目的性、果断性、自制力等方面。如能为学习和工作具有不怕苦和累的顽强拼搏精神，就是高志商。　　“志不强者智不达，言不信者行不果”、“勤能补拙是良训，一分辛劳一分才”。它们说明一个道理：志商对一个人的智慧具有重要的影响。人生是小志小成，大志大成。许多人一生平淡，不是因为没有才干，而是缺乏志向和清晰的发展目标。在商界尤其如此，要成就出色的事业，就得要有远大的志向。　　9. 灵商（SQ）　　灵商（Spiritual Intelligence Quotient，简写成SQ），就是对事物本质的灵感、顿悟能力和直觉思维能力。量子力学之父普朗克认为，富有创造性的科学家必须具有鲜明的直觉想像力。无论是阿基米德从洗澡中获得灵感最终发现了浮力定律，牛顿从掉下的苹果中得到启发发现了万有引力定律，还是凯库勒关于蛇首尾相连的梦而导致苯环结构的发现，都是科学史上灵商飞跃的不朽例证。成功人生没有定式，单靠成文的理论是解决不了实际问题的，还得需要悟性，需要灵商的闪现。修炼灵商，关键在于不断学习、观察、思考，要敢于大胆的假设，敢于突破传统思维。　　10.健商（HQ）　　健商（Health Intelligence Quotient，简写成HQ）是指个人所具有的健康意识、健康知识和健康能力的反映。健康是人生最大的财富，就好象健康是1，事业、爱情、金钱、家庭、友谊、权力等等是1后面的零，所以光有1的人生是远远不够的，但是失去了1（健康），后面的0再多对你也没有任何意义，正所谓平安是福。所以幸福的前提是关爱、珍惜自己生命，并努力地去创造、分享事业、爱情、财富、权力等等人生价值。

《RabbitMQ in Depth》（Gavin M. Roy）电子书网盘下载免费在线阅读资源链接：链接: https://pan.baidu.com/s/15gsKbuJna6GUJunGHE0mNA 提取码: 3sjy书名：RabbitMQ in Depth作者：Gavin M. Roy出版社：Manning Publications出版年份：2014页数：375内容简介：Any large application needs an efficient way to handle the constant messages passing between components in the system. Billed as "messaging that just works," the RabbitMQ message broker initially appeals to developers because it"s lightweight, easy to set up, and low maintenance. They stick with it, though, because it"s powerful, fast, and up to nearly anything you can throw at it. This book takes you beyond the basics and explores the challenges of clustering and distributing messages across enterprise-level data-centers using RabbitMQ.RabbitMQ in Depth is a practical guide to building and maintaining message-based systems. This book covers detailed architectural and operational use of RabbitMQ with an emphasis on not just how it works but why it works the way it does. You"ll find examples and detailed explanations of everything from low-level communication to integration with third-party systems. You"ll also find the insights you need to make core architectural choices and develop procedures for effective operational management.作者简介：Gavin M. Roy is an active open-source evangelist and advocate who has been working with Internet and Enterprise technologies since the mid-90"s. As the CTO of MeetMe.com, Gavin implemented RabbitMQ as the core of MeetMe"s event-based scalable application architecture. Gavin is a member of the Python Software Foundation and is the maintainer of pika, a pure-Python implementation of the AMQP protocol for RabbitMQ.

intel 处理器晶片后面的H,m,u,mx,hq.mq等是什么意思啊？给网址也可以。 H 不可拆卸 U 低电压 MX旗舰级， HQ支援vPro技术， MQ不支援vPro i7处理器后面的MQ HQ 这些代号是什么意思？ MQ是PGA插槽，可以自己换CPU。 HQ是BGA焊死的，不能自己换。 附： U 一般表示低电压版（一般功耗比较低） M 标识移动版（也就是笔记本处理器，一般双核） 英特尔的处理器后面的mq是什么意思 hq指焊死在主机板上的处理器，不能换，mq是可以换的。前面数字一样的效能没有区别 英特尔酷睿处理器，后面的HQ是什么意思？U呢？ 建议购买搭载了第六代智慧英特尔酷睿处理器的产品，高速视讯同步技术更支援最新的HDVC编解码全硬体加速，以及JPEG/MPEG的硬体加速，对4K视讯以及超高画素数码相片的编缉、压缩、格式转换、网上分享，一切处理转瞬完成，游戏体验更是游刃有余，推荐如下： Dell Vostro 3559D-1828B 轻薄 I7-6500U Window 10 Lenovo 700S-14ISK 轻薄 M7 SKL 14.0" Win 10 Consumer 12-Dec Lenovo Yoga 900-13ISK 游戏本 i7-6500HQ SKL 13.3" Win 10 11-Nov intel处理器后面的xm om lm qm um 都是什么意思啊？ M的意思是Mobile，处理器是为笔记本设计的，功耗和发热量较低，适合笔记本使用 X表示 Extreme，表示效能最高的 L表示Low voltage，指的是低电压版CPU，发热量跟标准版的相比大约只有一半。 U表示Ultra Low Voltage，超低电压版CPU，发热量和功耗比L系列的还要低。 Q表示Quad，强调这颗CPU是四核心的，而且标明Q的处理器只有笔记本系列的CPU，因为笔记本的处理器一般是双核的。另外桌上型电脑的CPU即使是四核，也不标明。 O没见过，Intel的CPU应该没有O结尾的处理器，可能是你弄错了。 CPU后面的XM,PM,HQ,QM,MQ,M,U都是什么意思? intel笔记本cpu的字尾。 QM是三代以前包括三代四核i7的字尾，到第四代QM变成MQ. XM是笔记本旗舰四核i7的字尾，有这个字尾的笔记本i7相比MQ或QM版本多了2MB三级快取并支援自由超频技术。 PM，这个字尾表示CPU没有核显。 HQ，这个字尾表示CPU核显加强且核心不是一般的Haswell。 QM，MQ：QM是三代以前标识四核i7的字尾，到第四代QM变成MQ。 M是最常见的，表示标准电压双核移动版本。 U是超低压笔记本CPU，主要用在超级本上，主频很低且均是双核处理器。 酷睿i7 4980HQ 这个处理器后面的HQ是什么意思？ 这是指焊接在主机板上的处理器，不能换的，效能相当的强劲。 AMD皓龙处理器后面的HE、SE、EE是什么意思 Special Edition (SE for short, and meaning higher clock speed and much hotter temperature) Highly Efficient (HE, and meaning lower voltage and therefore lower heat for a given clock speed) variants. EE—indicates a very low-power AMD Opteronu2122 processor. Performance of a very low-power AMD Opteron processor EE model number, xxxx EE, is equal to the performance of the same model number standard-power version. SE更高主频，也更高温度 HE低频版，跟Standard版比效能相同，功耗降低 EE为HE的更低功耗版 Intel 网络卡 后面的PM TM 等等是什么意思 因为要你自己解决

1FQ（FinancialIntelligenceQuotient），即财商。是指理财能力，特别是投资收益能力。2MQ德商（MoralIntelligenceQuotient，缩写成MQ），是指一个人的德性水平或道德人格品质。MQ钱商（MoneyQuotient），是一个人处理金钱以实现人生目标的能力总和。MQ心商就是维持心理健康、缓解心理压力、保持良好心理状况和活力的能力。MQ记忆商（MemoryQuotient，缩写成MQ）3SQ高灵商（SpiritualQuotient）：高灵商代表有正确的价值观，能否分辨是非，甄别真伪。4DQ发育商是用来衡量婴幼儿心智发展水平的核心指标之一。5AQ逆境商数是我们在面对逆境时的处理能力。

西门子 ER75K253MQ 更好！质量更稳定，但是贵1000元。以下是俩个产品的参数对比！西门子 ER75K253MQ适用气源天然气(12T)安装方式：台嵌两用熄保装置：支持点火方式：Digi 联控；Digi 瞬点；digi 时控。面板材质：高质感240号拉丝不锈钢额定热流量（KW）0.3-4.0kw欧欧慕(nathome) JZT-NG035 适用气源天然气(12T)安装方式：台嵌两用熄保装置：支持点火方式：脉冲电子点火面板材质：不锈钢额定热流量（KW）4.5

Freescale 的嵌入式实时操作系统，全称：MessageQueue eXecutive。相关资料可以在Freescale 官网下载：http://www.freescale.com/webapp/sps/site/homepage.jsp?code=MQX_HOME&tid=vanMQX

MQ算术编码器原理及实现 郭晴 北京邮电大学信息与通信工程学院，北京(100876) E-mail: 摘 要：JPEG2000标准中， MQ算术编码是熵编码的主要部分。MQ算术编码器是一种基于上下文的自适应二进制算术编码器。它基于上下文以利于解除信源相关性，利用条件交换和概率估计状态机中的贝叶斯学习过程实现符号概率模型自适应过程，采用位填充技术解决编码中的进位问题，是一种高效率物理可实现的压缩编码算法。本文从算术编码的基本原理入手，详细分析JPEG2000标准提供的MQ编码器编码原理，以及编码流程。利用C语言编程实现JPEG2000标准要求的MQ算术编码器，并分析MQ算术编码器中上下文引入对压缩效率的影响。 关键词：JPEG2000 ；算术编码；MQ算数编码器 中图分类号：TN911.21 1. 引言 随着多媒体技术的不断运用发展，图像压缩要求更高的性能和新的特征。为了满足静止图像在特殊领域编码的需求，JPEG2000作为一个新的标准处于不断的发展中，这种新的标准更加注重图像的可伸缩表述[1]。 算术编码是一种变长信源编码技术,其卓越性能使其在多媒体领域得到了越来越广泛的应用 [2]。JPEG2000标准中，提高图像压缩性能的关键技术之一就是MQ算术编码。MQ算术编码器是一种基于上下文的自适应二进制算术编码器,它继承了IBM的ABIC（自适应双层图像压缩）中Q编码器无乘法的近似和位缓存的策略,增加了条件交换和概率估计状态机中的贝叶斯学习过程，是一种高效率物理可实现的压缩编码算法，非常具有研究价值。 2. 算术编码 2.1编码原理简述 算术编码是一种非分组码。编码时信源符号序列连续的进入编码器，通过编码器的运算得到连续的输出。通常算术编码是讲一条信源符号序列映射成一条码序列，这样的码序列有时也称为码字。算术编码的实质就是，将一条信源信息序列映射到[0,1)区间中的一个子区间，这种映射是一种一一对应关系，以保证唯一译码，然后取这个子区间内的一点所代表的数值作为码字。只要码长合适，就可以保证唯一可译。而当信源序列长度足够大时，每信源符号的平均码长接近信源的熵[2]。 虽然其编码效率很高，但仍然存在缺陷。首先，其运算需要精确的实数加法和乘法，这些运算在有限精度的计算机上实现是非常困难的。正是这个原因使得算术编码从提出到实际应用相差了近二十年之久。直到Rissanen和Pasco分别提出了一个先进后出算法和一个先进先出算法，并由此证明了算术编码可以用有限精度处理技术逼近。Rubin吸收了两个算法的精华，利用有限精度寄存器，讨论了一般算术编码的实现方法。在此基础上，Witten，Neal和Cleary做了进一步地精细化，并给出了一个完整的C语言程序。 算术编码的另一缺陷是编码速度太低，这是因为编码迭代过程中含有整数乘除运算，这些运算对于软件执行和硬件设计是十分不利的。 为此Langdon和Rissanen提出了一个用移位和加法实现二进制算术编码的方法，并成功地应用于黑白二值图象的压缩编码。二进制算术编码是一种步进式编码译码过程。它不需 要等到待编序列完全输入编码器，就可以在序列输入的同时输出编码码字。它同时也解决了算术编码的精度问题。 2.2二进制算术编码 如前所述，二进制算术编码是一种增长型编码译码过程，序列进入编码器的同时可以得到编码输出，而不需要等到所有序列完全进入编码器。 以消息“cacbad”为例说明编码过程。开始时，整个区间是一个半开半闭区间R0=[0,1)，由各个符号概率仍然分解为四个部分：[0.5, 0.62)，(0.62, 0.70)，[0.70, 0.86)，[0.86, 0.9)以代表a，b，c，d区间。计数器Count初始设为0。 第一个符号为c，所属区间R1=[0.5,0.9)完全属于[0.5,1)，为情况2因此编码输出1bit：1。同时根据情况2改变区间大小为R2=[0.0,0.8)。由于Count＝0，因此不用输出任何码字。 第二个符号为a，区间调整为R3=[0.0, 0.24)。由于整个区间属于前半部分，为情况1，因此输出1bit：0，同时区间调整为R4[0.0,0.48)。仍然属于前半部分。继续输出0，调整区间到R5=[0.0,0.96)。 第三个符号为c，区间调整至R6=[0.48,0.864)。不需要输出任何码字也不需要调整区间。 第四个符号是b。区间调整至R7=[0.5952,0.672)，属于情况2，输出1，调整区间R8＝ [0.1904,0.344)。情况1，输出0，调整区间为R9=[0.3808,0.688)。 此时区间属于情况3，因此我们对计数器加1：Count＝1，同时调整区间为R10=[0.2616,0.876)。 第五个符号是a，区间调整为R11=[0.2616,0.44592)，情况1，输出0，同时调整区间R12=[0.5232,0.89184)。此时计数器大于0，因此输出计数器值1bit：1。新的区间为情况1，因此输出1，调整至R13=[0.0464,0.78368)。 最后一个符号是d，区间调整至R14=[0.709952,0.78368)。情况2，输出1，调整为R15=[0.419904,0.56736)。此时我们结束编码，可以用此区间内任意值作为码字输出。不妨取0.5，则二进制表示为0.1000000b，可以添加任意多个0以满足位数要求。 因此作为唯一可译编码，编码过程中输出的码字与最后区间内任一数值结合，串起来即实际16bit编码：1001 0011 1100 0000。可以看到，前9bit为增长编码过程输出，最后7bit为从区间中选择与前9bit共同组成16bit编码。 详细编码过程如图1： 图1 “cacbad”二进制算术编码过程图 3. MQ算术编码器原理 3.1 MQ编码器结构 JPEG2000标准中的MQ编码器结构如图2所示，编码器输入由待编码位D和上下文矢量CX构成，他们是由EBCOT (嵌入式位平面失真率可优化编码)成对产生的。CX是位平面编码中根据邻域相关性归纳而来的概率统计模型，共有l9种。即对于不同的CX，符号概率不相同。 图2 MQ编码器结构图 3.2递归区间划分以及编码近似 递归概率区间分割的ELIAS编码是二进制算术编码的基础[3]。算术编码器首先按符号概率将符号分为大概率符号MPS和小概率符号LPS。区间划分时，LPS区间在MPS区间之前。如图2： 图3 MQ编码器编码区间示意图 当对MPS进行编码时，LPS子区间间隔就被加到编码串上。因而对每一位进行编码时，必须预先知道LPS子间隔的大小和MPS的代表符号。编码过程就是对输入的每一位进行判定，不断地改变编码串C的值，使它指向当前间隔底端。编码过程用二进制分数加法代替整数码字的串加，概率越大的二进制位可以用分数位进行编码，从而减少编码的位数，达到压缩的效果。 假设A为当前问隔，而Qe为LPS的估计概率。那么对间隔进行准确的划分，必须满足以下式子： MPS子区间间隔=A-(Qe*A) (1) LPS子区间间隔＝Qe*A (2) 为了避免硬件较难实现的乘法运算，在JPEG2000中用下面式子代替来避免乘法运算： MPS子区间间隔=A-(Qe*A) (3) LPS子区间间隔＝Qe*A (4) 编码时对运算进行简化，直接用小概率符号概率Qe代替LPS区间长度Qe*A，以消除乘法运算。当对MPS进行编码时，编码串的值加上Qe，而间隔减少为A-Qe 。而当对LPS进行编码时，编码串C不变，间隔减小为Qe。然后根据需要对A和C进行归一化，使A落在0．75～1．5的区间内(原始全概率区间为[0,1.5),0.75为中点值）[4]。其相应的整形表示为保持A大于0x8000。若小于这个值，则通过重整化过程，对寄存器C和A进行左移位处理。 由于区间分割采用这样的近似，可能在某些时候使LPS的概率比MPS的大。如当A值为0.75，而Q为0.5时，MPS的概率就为A-Qe =0.25。为避免这种倒置现象，当LPS的间隔比MPS大时，就对它们进行互换。 3.3自适应模型 前文描述的算术编码过程，均建立在已知各个符号概率的基础上。只有已知各符号概率才能根据其划分概率区间。而实际中各符号概率必须通过概率统计模型得到。模型提供了被编码符号的概率，编码算法利用相应概率实现对符号编码。JPEG2000中的算术编码采用基于上下文矢量的自适应模型。 一方面，符号概率的确定是一个自适应过程。利用概率转移有限状态机根据输入消息符号，实时调整符号概率。另一方面，其状态转移是基于上下文的过程。编码器输入不仅有消息序列D，还包括上下文CX。对于同一消息D，其上下文CX不同，则对应的符号概率并不一定相同。必须读取CX当前状态的符号概率来确定消息的符号概率，同时决定是否要转移到下一状态。符号概率的状态转移表由标准提供，共47种状态。 3.4位填充技术 在二进制算术编码中，由于编码过程采用增长传输技术，必须保证当前编码字节有进位时，不影响到编码器已经输出的字节。MQ算术编码器采用了位填充（bit-stuffing）技术解决进位问题[5]。 位填充技术的原理是在编码出现进位，造成缓存中上一待输出字节溢出时，将进位标志作为当前字节编码的一部分，而不加在上一码字上。 这种情况只会在上一码字为0xff时出现。同时为了便于译码，当上一字节为0xfe，且当前字节出现进位，使得上一字节变为0xff时，当前字节进位标志0仍然作为编码输出。这样在译码时，凡碰到码字为0xff，则对下一码字第一比特均按进位标志处理即可。 4. MQ算术编码器实现以及结果分析 4.1编码器流程 图4 MQ编码器总流程图 总流程如上图4。首先对编码器进行初始化INTENC，然后读入上下文CX和待编字D开始编码ENCODE。直到编码结束时，通过FLUSH过程清空寄存器完成编码。 ENCODE流程如下图5，编码时判断D为0还是为1。为0则进行0编码CODE0，为1则进行1编码CODE1。 图5 ENCODE流程图 CODE0编码时，判断0是否为大概率符号。若是则进行大概率符号编码CODEMPS，否则进行小概率符号编码。CODE1编码类似。流程如图6、7。 图6 CODE0流程图 图7 CODE1流程图 4.2结果及分析 首先考察不引入上下文CX时的压缩性能。只要在上下文生成时仅生成一种上下文CX(0),则信源相当于未引入上下文的单符号独立随机信源。0符号概率为70％时的压缩率。引入上下文后压缩率接近68%，性能有所提高。 由于测试的信源未经过JPEG2000前处理步骤，因此这个压缩率仅能提供一定参考。 5. 结论 本文给出了MQ算术编码器原理以及实现流程，利用简单的模型初步探讨了上下文CX在编码中的作用。要进行更深入的研究，必须对JPEG2000编码的其他模块做进一步的研究分析，理解CX在JPEG2000中的产生机制，将前面的模块与算术编码器结合起来，分析它们的性能。 参考文献 [1] [2] [3] [4] 王芳, 汪伟. JPEG2000图像压缩标准及其应用 [J].光盘技术.第一期.2006,1:57-59. 田宝玉. 工程信息论 [M].北京邮电大学出版社.2004:108-116. 李文彬, 朱红. JPEG2000算术编码的研究及其FPGA设计 [J].遥测遥控. 26卷.2005, 5:38~40. JIN LI. Image Compression: The Mathematics of JPEG 2000 [J].Modern Signal Processing. Volume 46, 2003:185-221 [5] Tinku, Acharya, Ping-Sing, Tsai. JPEG2000 Standard for Image Compression: Concepts [J], Algorithms and VLSI Architectures. JOHN WILEY & SONS, INC.2004:30~195. The principle and realization of MQ arithmetic coding GuoQing Beijing University of Posts and Telecommunications (100876) Abstract MQ arithmetic coding is the most important part of entropy coding. MQ arithmetic coding is a context-based adaptive binary arithmetic encoder. It is based on the context in order to improve the coding efficiency. This paper explains the arithmetic coding theory, then further elaborated binary arithmetic coding theory and practical application of how to achieve finite precision arithmetic coder. Keywords: JPEG2000 arithmetic coding MQ-coder

TerransForceT72080MQ97SH2装win10系统步骤是怎样的？TerransForceT72080MQ97SH2是一款17.3英寸，预装Windows10，重2.6Kg，长度399mm，宽度268mm的影音娱乐本。处理器采用英特尔酷睿i78代系列，CPU主频2.6GHz，六核心/十二线程，内存容量32GB（16GB×2）DDR42666MHz，硬盘是混合硬盘（2×512GBSSD+5400转HDD），1TB+1TB。搭载NVIDIAGeForceRTX2080Max-Q发烧级独立显卡，显存容量8GBGDDR6。这边小编跟大家分享TerransForceT72080MQ97SH2用u盘重装win10系统的图文步骤。一、准备工作1、8G或更大容量空U盘2、制作uefipe启动盘：微pe工具箱怎么制作u盘启动盘(UEFILegacy双模式)3、win10系统下载：深度技术ghostwin1064位专业破解版v2019.07二、TerransForceT72080MQ97SH2笔记本重装win10步骤如下1、制作好uefi启动盘之后，将下载的win10系统iso镜像直接复制到U盘；2、在TerransForceT72080MQ97SH2笔记本电脑上插入uefi启动U盘，开机启动过程中，不停按F7或F11调出启动菜单，选择带UEFI的U盘启动项，按回车键即可进入U盘启动；3、进入到pe之后，双击桌面上的【分区助手(无损)】，选择磁盘1，点击【快速分区】；4、给TerransForceT72080MQ97SH2笔记本电脑设置分区数目、分区大小以及分区类型，卷标为【系统】的系统盘建议60G以上，由于选择了UEFI启动，磁盘类型要选择GPT，确认无误后点击开始执行；5、完成分区之后，打开此电脑—微PE工具箱，右键点击win10系统iso镜像，选择【装载】，如果没有装载选项，右键—打开方式—资源管理器；6、双击【双击安装系统.exe】，运行安装工具，选择【还原分区】，GHOWIMISO映像路径会自动提取到win10.gho，接着选择安装位置，一般是C盘，或者根据卷标或总大小来判断，选择之后，点击确定；7、如果弹出这个提示，点击是，继续执行；8、弹出这个对话框，选择完成后重启以及引导修复，点击是；9、弹出这个界面，执行win10系统安装部署到C盘的过程，需要等待一段时间；10、操作完成后，10秒后会自动重启TerransForceT72080MQ97SH2笔记本，重启过程拔出U盘，之后启动进入到这个界面，执行win10系统组件安装、驱动安装以及激活操作；11、在启动进入win10系统桌面之后，TerransForceT72080MQ97SH2笔记本重装win10系统过程结束。以上就是未来人来TerransForceT72080MQ97SH2笔记本重装win10系统详细步骤，如果你需要给TerransForceT72080MQ97SH2笔记本装系统，可以学习下这个教程。

my qq music说明是QQ音乐的歌在其它音乐播放软件里。

音乐文件格式，可以转化为MP3等格式进行播放，在qq音乐下载后可以转换，打开“qq音乐”进入软件主界面，在主莱单中选择“音频转码”进行转换。

1FQ（FinancialIntelligenceQuotient），即财商。是指理财能力，特别是投资收益能力。2MQ德商（MoralIntelligenceQuotient，缩写成MQ），是指一个人的德性水平或道德人格品质。MQ钱商（MoneyQuotient），是一个人处理金钱以实现人生目标的能力总和。MQ心商就是维持心理健康、缓解心理压力、保持良好心理状况和活力的能力。MQ记忆商（MemoryQuotient，缩写成MQ）3SQ高灵商（SpiritualQuotient）：高灵商代表有正确的价值观，能否分辨是非，甄别真伪。4DQ发育商是用来衡量婴幼儿心智发展水平的核心指标之一。5AQ逆境商数是我们在面对逆境时的处理能力。

1 FQ（Financial Intelligence Quotient），即财商。是指理财能力，特别是投资收益能力。2 MQ 德商（Moral Intelligence Quotient，缩写成MQ），是指一个人的德性水平或道德人格品质。 MQ 钱商（Money Quotient），是一个人处理金钱以实现人生目标的能力总和。 MQ 心商 就是维持心理健康、缓解心理压力、保持良好心理状况和活力的能力。 MQ 记忆商（Memory Quotient，缩写成MQ）3 SQ 高灵商（Spiritual Quotient）：高灵商代表有正确的价值观，能否分辨是非，甄别真伪。4 DQ 发育商 是用来衡量婴幼儿心智发展水平的核心指标之一。5 AQ 逆境商数 是我们在面对逆境时的处理能力。

tuxedo是交易中间件，处理海量、并发、分布式的事务处理；MQ是消息中间件，处理准同步的消息传递和处理；tuxedo在金融、电信业广泛使用，MQ我也就知道用在网管和文件传递这块。

QQ聊天软件

3GQQ

笔记本cpuhqhmq什么区别先介绍下CPU后面字母的含义：1.H：指高电压版本；2.QH：至高性能高电压版本；3.MQ：标准电压至高性能版本最大的区别就是：1.处理器所需要的电压不一样，是高电压还是标准电压。2.处理器性能不一样，是高性能处理器还是至高性能处理器。先介绍下cpu后面字母的含义：1.h：指高电压版本；2.qh：至高性能高电压版本；3.mq：标准电压至高性能版本最大的区别就是：1.处理器所需要的电压不一样，是高电压还是标准电压。2.处理器性能不一样，是高性能处理器还是至高性能处理器。BIOS里面的cpuHostFrequency是什么意思？CPUHostFrequency是设置CPU外频的选项.超频时会用到.所谓超频，就是让CPU工作在高于其额定的频率之下，以榨取其潜力和性能。超频可以使CPU的性能得到一定的提升，举个例子，把P42.4的频率超频至2800MHz，就可以让它达到P42.8的性能水平，从而少花钱用好东西。合理的超频对系统不会有太大的危害，只是发热量大一些罢了，如果超的太过火，会严重缩短配件的寿命，甚至烧毁。超频须要主板的BIOS支持，至于能超多少则取决于主板和CPU还有散热系统。最普通的超法：进入BIOS，再进入“频率/电压控制，然后将CPUHostClockControl一项的值设为Enabled，进行具体调节。现在的CPU都锁了倍频，因此我们只能从外频上做手脚，外频一项的名称叫做CPUHostFrequency，右侧则是相对应的数值。超频要循序渐进，不要一次超的太多，要随时观察温度，随机应变，找到最适合自己的频率。

Q:J c:J/(kg0C) m:kg T:0C q:J/kg Q=cm△t是一定质量的物质升高或降低一定的温度所吸收或放出的热量 Q=mq(Q=vq)是一定质量的物质燃烧所产生的能量,由化学能转化成热能.

看热值的单位，如果是J/Kg，用Q放=qm；如果是J/m3，用Q放=qV，一般固体Q=mq气体Q=qv望采纳

q=Q放/m（固体），q=Q放/v（气体）。v指的是燃烧多少立方米的气体所释放的热量，m指的是燃烧多少质量的固体所释放的热量。热值用符号q表示，单位是千焦每千克。 什么是热值 热值，又称卡值或发热量。1千克某种固体（气体）燃料完全燃烧放出的热量称为该燃料的热值，属于物质的特性，符号是q，单位是焦耳每千克，符号是J/kg。热值反映了燃料燃烧特性，即不同燃料在燃烧过程中化学能转化为内能的本领大小。

不是一个概念，mq200是手动挡变速箱，Tiptronic是6速手自一体变速箱

具体方法不一样。希望我的回答可以帮到你，有什么不懂可以追问。

设置说明如下: iot 有如下两个设备：testA,testB A、B分别有两个不同的证书 ，两个证书分别有不同的策略。 现在需要通过testA设备，操作testB设备的shadow，testA策略如下： 注意： iot:Publish、iot:Receive、iot:Subscribe以及topic / topicfilter的设置，与aws文档说明稍有不同。按aws文档会有问题

微型车

没有smqrt车型，正确写法为smart，smart车型属于双座微型小车。smart是德国梅赛德斯-奔驰与手表巨头瑞士Swatch公司合作的产物。名称中的S代表了斯沃奇，M代表了梅赛德斯-奔驰，art意为艺术，代表了双方合作的艺术性，Smart搭载的电力驱动系统包括一个55kW电机和16.7kwh电池组，续航里程达到145km，在内饰设计上，这款概念车的极简化设计模仿了摩托艇的内饰设计，驾驶员和副驾驶各拥有一个独立的罗盘箱。扩展资料SMH Swatch于1989年就有smart Car的计划，1991年德国福斯汽车也曾参与该计划。Mercedes-Benz 则在1993年有微型车Vision A计划。1994 年M-Benz与Swatch合组而成MCC(Micro Compact Car)公司(持股比例 Swatch 19%、M-Benz 81%)，正式开始名为Smart的微型车计划，研究车长在3米以内的都市迷你小车，计划于法国Hambach生产，总部则设在德国。参考资料来源：百度百科-smart

　　MQ Java Binding方式使用JNI(Java Native Interface)类似于MQ 服务器应用程序。　　MQSeries Java客户机服务器连接最快的方式是MQ Java Binding方式，这种方式要求MQ Java应用和MQ Server在同一台机器上。使用MQ Java Binding方式避免了建立网络连接的开销，因此，当连接对性能影响很大时，应当选用MQ Java Binding方式。　　MQ Java Client方式通过Server端定义的服务器连接通道连接，服务器方需要启动侦听程序。MQ Java Client方式用于Java客户程序和服务器不在同一台机器时进行连接。　　客户端连接，建立MQEnvironment类　　MQEnvironment.hostname　　以下是，客户端连接例子　　// ===========================================================================　　//　　// Licensed Materials - Property of IBM　　//　　// 5639-C34　　//　　// (c) Copyright IBM Corp. 1995,1999　　//　　// ===========================================================================　　// WebSphere MQ M"z Java f sample applet　　//　　// This sample runs as an applet using the appletviewer and HTML file,　　// using the command :-　　// appletviewer MQSample.html　　// Output is to the command line, NOT the applet viewer window.　　//　　// Note. If you receive WebSphere MQ error 2 reason 2059 and you are sure your　　// WebSphere MQ and TCP/IP setup is correct,　　// you should click on the "Applet" selection in the Applet viewer window　　// select properties, and change "Network access" to unrestricted.　　import com.ibm.mq.*; // Include the WebSphere MQ classes for Java package　　public class MQSample extends java.applet.Applet　　{　　private String hostname = "your_hostname"; // define the name of your　　// host to connect to　　private String channel = "server_channel"; // define name of channel　　// for client to use　　// Note. assumes WebSphere MQ Server　　// is listening on the default　　// TCP/IP port of 1414　　private String qManager = "your_Q_manager"; // define name of queue　　// manager object to　　// connect to.　　private MQQueueManager qMgr; // define a queue manager object　　// When the class is called, this initialization is done first.　　public void init()　　{　　// Set up WebSphere MQ environment　　MQEnvironment.hostname = hostname; // Could have put the　　// hostname & channel　　MQEnvironment.channel = channel; // string directly here!　　MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,//Set TCP/IP or server　　MQC.TRANSPORT_MQSERIES);//Connection　　} // end of init　　public void start()　　{　　try {　　// Create a connection to the queue manager　　qMgr = new MQQueueManager(qManager);　　// Set up the options on the queue we wish to open...　　// Note. All WebSphere MQ Options are prefixed with MQC in Java.　　int openOptions = MQC.MQOO_INPUT_AS_Q_DEF |　　MQC.MQOO_OUTPUT ;　　// Now specify the queue that we wish to open, and the open options...　　MQQueue system_default_local_queue =　　qMgr.accessQueue("SYSTEM.DEFAULT.LOCAL.QUEUE",　　openOptions);　　// Define a simple WebSphere MQ message, and write some text in UTF format..　　MQMessage hello_world = new MQMessage();　　hello_world.writeUTF("Hello World!");　　// specify the message options...　　MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults,　　// same as　　// MQPMO_DEFAULT　　// constant　　// put the message on the queue　　system_default_local_queue.put(hello_world,pmo);　　// get the message back again...　　// First define WebSphere MQ message buffer to receive the message into..　　MQMessage retrievedMessage = new MQMessage();　　retrievedMessage.messageId = hello_world.messageId;　　// Set the get message options..　　MQGetMessageOptions gmo = new MQGetMessageOptions(); // accept the defaults　　// same as　　// MQGMO_DEFAULT　　// get the message off the queue..　　system_default_local_queue.get(retrievedMessage, gmo);　　// And prove we have the message by displaying the UTF message text　　String msgText = retrievedMessage.readUTF();　　System.out.println("The message is: " + msgText);　　// Close the queue　　system_default_local_queue.close();　　// Disconnect from the queue manager　　qMgr.disconnect();　　}　　// If an error has occurred in the above, try to identify what went wrong.　　// Was it WebSphere MQ error?　　< 1. WebSphere MQ classes for Java >} applet (2/3)　　>}zk　　62 WebSphere MQ 9C Java　　>}&CLrzk　　TBzkN]>;vr%D&CLr,|9Cs(==:　　1. ,S=SPmw　　2. +{"Ek SYSTEM.DEFAULT.LOCAL.QUEUE　　3. YN!5XD{"　　catch (MQException ex)　　{　　System.out.println("WebSphere MQ error occurred : Completion code " +　　ex.completionCode +　　" Reason code " + ex.reasonCode);　　}　　// Was it a Java buffer space error?　　catch (java.io.IOException ex)　　{　　System.out.println("An error occurred whilst writing to the　　message buffer: " + ex);　　}　　} // end of start　　} // end of sample

bindingkey是队列和交换机之间的绑定key，而routingkey是生产者发给交换机的一个信息，当routingkey和bindingkey能对应上的时候就发到相应的队列中

1、首先确认网络和端口是否通ping iptelnet ip 端口2、确认接收方监听是否开启。 ps -ef |grep runmqlsr (aix系统)3、重置通道

Prometheus的简单配置，如下： 正则的匹配符号： !~ 去除匹配的内容， =~ 只保留匹配的内容。例如，你可以对uri进行正则匹配： Grafana是一个非常强大的可视化软件。使用起来也非常简单。具体请参阅官方文档。

websphere mq : 用于传输信息 具有跨平台的功能。1 安装websphere mq 并启动2 websphere mq 建立 queue Manager (如：MQSI_SAMPLE_QM)3 建立queue 类型选择 Local类型 的 （如lq ）3 建立channels 类型选择Server Connection （如BridgeChannel）java 代码如下：package test.mq;import com.ibm.mq.*;/* * 成功的访问mq 的java 类 */public class FirstMqTest {// public static void main(String[] args[]){// FirstMqTest first = new FirstMqTest();// first.test();// } public static void main(String args[]){ FirstMqTest first = new FirstMqTest(); first.test(); } public void test(){ String qManager = "MQSI_SAMPLE_QM"; //QueueManager name String qName = "lq";//Queue Name try { //configure connection parameters MQEnvironment.hostname="172.16.17.123";//MQ Server name or IP //MQEnvironment.port=1414;//listenr port MQEnvironment.channel="BridgeChannel";//Server-Connection Channel MQEnvironment.CCSID =1381; // Create a connection to the QueueManager System.out.println("Connecting to queue manager: "+qManager); MQQueueManager qMgr = new MQQueueManager(qManager); // Set up the options on the queue we wish to open int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT; // Now specify the queue that we wish to open and the open options System.out.println("Accessing queue: "+qName); MQQueue queue = qMgr.accessQueue(qName, openOptions); // Define a simple WebSphere MQ Message ... MQMessage msg = new MQMessage(); // ... and write some text in UTF8 format msg.writeUTF("Hello, World!"); // Specify the default put message options MQPutMessageOptions pmo = new MQPutMessageOptions(); // Put the message to the queue System.out.println("Sending a message..."); /* * 在此测试一下 mq 的传输次列 * */ for(int j=0;j< 5;j++){ String str ="test11111111111"; str = str+j; msg.writeUTF(str); queue.put(msg, pmo); } queue.put(msg, pmo); // Now get the message back again. First define a WebSphere MQ message // to receive the data MQMessage rcvMessage = new MQMessage(); // Specify default get message options MQGetMessageOptions gmo = new MQGetMessageOptions(); // Get the message off the queue. System.out.println("...and getting the message back again"); queue.get(rcvMessage, gmo); // And display the message text... String msgText = rcvMessage.readUTF(); System.out.println("The message is: " + msgText); // Close the queue System.out.println("Closing the queue"); queue.close(); // Disconnect from the QueueManager System.out.println("Disconnecting from the Queue Manager"); qMgr.disconnect(); System.out.println("Done!"); } catch (MQException ex) { System.out.println("A WebSphere MQ Error occured : Completion Code " + ex.completionCode + " Reason Code " + ex.reasonCode); } catch (java.io.IOException ex) { System.out.println("An IOException occured whilst writing to the message buffer: " + ex); } }}

websphere mq : 用于传输信息 具有跨平台的功能。1 安装websphere mq 并启动2 websphere mq 建立 queue Manager (如：MQSI_SAMPLE_QM)3 建立queue 类型选择 Local类型 的 （如lq ）3 建立channels 类型选择Server Connection （如BridgeChannel）java 代码如下：package test.mq;import com.ibm.mq.*;/* * 成功的访问mq 的java 类 */public class FirstMqTest {// public static void main(String[] args[]){// FirstMqTest first = new FirstMqTest();// first.test();// } public static void main(String args[]){ FirstMqTest first = new FirstMqTest(); first.test(); } public void test(){ String qManager = "MQSI_SAMPLE_QM"; //QueueManager name String qName = "lq";//Queue Name try { //configure connection parameters MQEnvironment.hostname="172.16.17.123";//MQ Server name or IP //MQEnvironment.port=1414;//listenr port MQEnvironment.channel="BridgeChannel";//Server-Connection Channel MQEnvironment.CCSID =1381; // Create a connection to the QueueManager System.out.println("Connecting to queue manager: "+qManager); MQQueueManager qMgr = new MQQueueManager(qManager); // Set up the options on the queue we wish to open int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT; // Now specify the queue that we wish to open and the open options System.out.println("Accessing queue: "+qName); MQQueue queue = qMgr.accessQueue(qName, openOptions); // Define a simple WebSphere MQ Message ... MQMessage msg = new MQMessage(); // ... and write some text in UTF8 format msg.writeUTF("Hello, World!"); // Specify the default put message options MQPutMessageOptions pmo = new MQPutMessageOptions(); // Put the message to the queue System.out.println("Sending a message..."); /* * 在此测试一下 mq 的传输次列 * */ for(int j=0;j< 5;j++){ String str ="test11111111111"; str = str+j; msg.writeUTF(str); queue.put(msg, pmo); } queue.put(msg, pmo); // Now get the message back again. First define a WebSphere MQ message // to receive the data MQMessage rcvMessage = new MQMessage(); // Specify default get message options MQGetMessageOptions gmo = new MQGetMessageOptions(); // Get the message off the queue. System.out.println("...and getting the message back again"); queue.get(rcvMessage, gmo); // And display the message text... String msgText = rcvMessage.readUTF(); System.out.println("The message is: " + msgText); // Close the queue System.out.println("Closing the queue"); queue.close(); // Disconnect from the QueueManager System.out.println("Disconnecting from the Queue Manager"); qMgr.disconnect(); System.out.println("Done!"); } catch (MQException ex) { System.out.println("A WebSphere MQ Error occured : Completion Code " + ex.completionCode + " Reason Code " + ex.reasonCode); } catch (java.io.IOException ex) { System.out.println("An IOException occured whilst writing to the message buffer: " + ex); } }}

1、队列管理器需要定义一个用于连接队列管理器的服务器连接通道。与5.3版本不同的是，这个通道不一定是SYSTEM.ADMIN.SVRCONN。该通道的名字可以随意定义，在设置远程管理的时候在 WebSphere MQ 资源管理器中指定即可。需要注意的是，启动WebSphere MQ 资源管理器的机器上的当前用户可能没有访问队列管理器对象的权限，导致 MQ 资源管理器无法管理远程队列管理器。简单的方法是在定义服务器连接通道的时候设置该通道的 MCAUSER 属性为mqm组中的用户。 DEFINE CHANNEL(SYSTEM.ADMIN.SVRCONN) CHLTYPE(SVRCONN) TRPTYPE(TCP) MCAUSER(单引号mqm单引号)(郁闷啊，单引号居然会被转掉，记住上面要用单引号)2、队列管理器需要定义一个名为 SYSTEM.MQEXPLORER.REPLY.MODEL 的临时模型队列以和MQ 资源管理器通信： DEFINE QM(SYSTEM.MQEXPLORER.REPLY.MODEL) DEFTYPE(TEMPDYN)3、队列管理器需要启动命令服务器 strmqcsv <QMNAME>4、队列管理器需要启动侦听： DEFINE LISTENER(TCP.LSTENER) TRPTYPE(TCP) PORT(1414) START LISTENER(TCP.LISTENER)如果远程队列管理器是在Windows下用图形界面建立的，则1、2、3步都已经默认做好了。只需要做第4步即可完成以上步骤后，就可以在 MQ 资源管理器中按照下面步骤连接队列管理器： 1、打开 WebSphere MQ 资源管理器；右键点击队列管理器导航器中的队列管理器文件夹，选择“显示/隐藏队列管理器”：2、在弹出的“显示/隐藏队列管理器”对话框中选择“添加”按钮：3、在“添加队列管理器”对话框中选择直接连接，并输入队列管理器名称（一定要和远程队列管理器名称一致），然后点击下一步：4、填入主机名或 IP 地址、队列管理器侦听端口、以及服务器连接通道，然后点击完成即可。间接接连接设置步骤 WebSphere MQ 资源管理器不但可以通过直接连接管理远程队列管理器，还可以通过队列管理器间接管理一个队列管理器。其基本原理为：作为间接队列管理器的队列管理能将消息路由自动到目标队列管理器。其设置方法如下： 仍然延续前面的例子，我们将实现MQ 资源管理器对与 ERP.QM1 在同一台机器的另外一个队列管理器 ERP.QM2 的远程管理。 1、在队列管理器 ERP.QM2 上进行如下设置： /* 定义/启动侦听 */ DEF LISTENER(TCP.LISTENER) TRPTYPE(TCP) PORT(1415) START LISTENTER(TCP.LISTENER)/* 定义与ERP.QM1 同名的传输队列 */ DEF QL(ERP.QM1) USAGE(XMITQ) TRIGGER TRIGTYPE(FIRST) INITQ(SYSTEM.CHANNEL.INITQ) TRIGDATA(QM2.TO.QM1)/* 定义ERP.QM2 到 ERP.QM1 的发送通道*/ DEF CHANNEL(QM2.TO.QM1) CHLTYPE(SDR) TRPTYPE(TCP) CONNAME(9.181.159.231) XMITQ(ERP.QM1)/* 定义ERP.QM1 到 ERP.QM2 的接收通道*/ DEF CHANNEL(QM1.TO.QM2) CHLTYPE(RCVR) TRPTYPE(TCP)2、在队列管理器 ERP.QM1 上进行如下设置： /* 定义与目标队列管理器同名的传输队列 */ DEF QL(ERP.QM2) USAGE(XMITQ) TRIGGER TRIGTYPE(FIRST) INITQ(SYSTEM.CHANNEL.INITQ) TRIGDATA(QM1.TO.QM2)/* 定义ERP.QM1 到 ERP.QM2 的发送通道*/ DEF CHANNEL(QM1.TO.QM2) CHLTYPE(SDR) TRPTYPE(TCP) CONNAME("9.181.159.231(1415)") XMITQ(ERP.QM2)/* 定义ERP.QM1 到 ERP.QM2 的接收通道*/ DEF CHANNEL(QM2.TO.QM1) CHLTYPE(RCVR) TRPTYPE(TCP)3、启动队列管理器 ERP.QM2 的命令服务器： strmqcsv ERP.QM2配置远程管理： 1、打开 WebSphere MQ 资源管理器；右键点击队列管理器导航器中的队列管理器文件夹，选择“显示/隐藏队列管理器”： 2、在弹出的“显示/隐藏队列管理器”对话框中选择“添加”按钮： 3、在“添加队列管理器”对话框中选择“使用中间队列管理器进行连接”，并输入队列管理器名称，然后点击下一步：4、在中间队列管理器下拉选项中选择 ERP.QM1 点击完成即可。

websphere mq : 用于传输信息 具有跨平台的功能。1 安装websphere mq 并启动2 websphere mq 建立 queue Manager (如：MQSI_SAMPLE_QM)3 建立queue 类型选择 Local类型 的 （如lq ）3 建立channels 类型选择Server Connection （如BridgeChannel）java 代码如下：package test.mq;import com.ibm.mq.*;/* * 成功的访问mq 的java 类 */public class FirstMqTest {// public static void main(String[] args[]){// FirstMqTest first = new FirstMqTest();// first.test();// } public static void main(String args[]){ FirstMqTest first = new FirstMqTest(); first.test(); } public void test(){ String qManager = "MQSI_SAMPLE_QM"; //QueueManager name String qName = "lq";//Queue Name try { //configure connection parameters MQEnvironment.hostname="172.16.17.123";//MQ Server name or IP //MQEnvironment.port=1414;//listenr port MQEnvironment.channel="BridgeChannel";//Server-Connection Channel MQEnvironment.CCSID =1381; // Create a connection to the QueueManager System.out.println("Connecting to queue manager: "+qManager); MQQueueManager qMgr = new MQQueueManager(qManager); // Set up the options on the queue we wish to open int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT; // Now specify the queue that we wish to open and the open options System.out.println("Accessing queue: "+qName); MQQueue queue = qMgr.accessQueue(qName, openOptions); // Define a simple WebSphere MQ Message ... MQMessage msg = new MQMessage(); // ... and write some text in UTF8 format msg.writeUTF("Hello, World!"); // Specify the default put message options MQPutMessageOptions pmo = new MQPutMessageOptions(); // Put the message to the queue System.out.println("Sending a message..."); /* * 在此测试一下 mq 的传输次列 * */ for(int j=0;j< 5;j++){ String str ="test11111111111"; str = str+j; msg.writeUTF(str); queue.put(msg, pmo); } queue.put(msg, pmo); // Now get the message back again. First define a WebSphere MQ message // to receive the data MQMessage rcvMessage = new MQMessage(); // Specify default get message options MQGetMessageOptions gmo = new MQGetMessageOptions(); // Get the message off the queue. System.out.println("...and getting the message back again"); queue.get(rcvMessage, gmo); // And display the message text... String msgText = rcvMessage.readUTF(); System.out.println("The message is: " + msgText); // Close the queue System.out.println("Closing the queue"); queue.close(); // Disconnect from the QueueManager System.out.println("Disconnecting from the Queue Manager"); qMgr.disconnect(); System.out.println("Done!"); } catch (MQException ex) { System.out.println("A WebSphere MQ Error occured : Completion Code " + ex.completionCode + " Reason Code " + ex.reasonCode); } catch (java.io.IOException ex) { System.out.println("An IOException occured whilst writing to the message buffer: " + ex); } }}

websphere mq : 用于传输信息 具有跨平台的功能。1 安装websphere mq 并启动2 websphere mq 建立 queue Manager (如：MQSI_SAMPLE_QM)3 建立queue 类型选择 Local类型 的 （如lq ）3 建立channels 类型选择Server Connection （如BridgeChannel）java 代码如下：package test.mq;import com.ibm.mq.*;/** 成功的访问mq 的java 类*/public class FirstMqTest {// public static void main(String[] args[]){// FirstMqTest first = new FirstMqTest();// first.test();// }public static void main(String args[]){FirstMqTest first = new FirstMqTest();first.test();}public void test(){String qManager = "MQSI_SAMPLE_QM"; //QueueManager nameString qName = "lq";//Queue Nametry {//configure connection parametersMQEnvironment.hostname="172.16.17.123";//MQ Server name or IP//MQEnvironment.port=1414;//listenr portMQEnvironment.channel="BridgeChannel";//Server-Connection ChannelMQEnvironment.CCSID =1381;// Create a connection to the QueueManagerSystem.out.println("Connecting to queue manager: "+qManager);MQQueueManager qMgr = new MQQueueManager(qManager);// Set up the options on the queue we wish to open int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;// Now specify the queue that we wish to open and the open optionsSystem.out.println("Accessing queue: "+qName);MQQueue queue = qMgr.accessQueue(qName, openOptions);// Define a simple WebSphere MQ Message ... MQMessage msg = new MQMessage();// ... and write some text in UTF8 formatmsg.writeUTF("Hello, World!");// Specify the default put message optionsMQPutMessageOptions pmo = new MQPutMessageOptions();// Put the message to the queueSystem.out.println("Sending a message...");/** 在此测试一下 mq 的传输次列* */for(int j=0;j< 5;j++){String str ="test11111111111";str = str+j;msg.writeUTF(str);queue.put(msg, pmo);}queue.put(msg, pmo);// Now get the message back again. First define a WebSphere MQ message // to receive the data MQMessage rcvMessage = new MQMessage();// Specify default get message options MQGetMessageOptions gmo = new MQGetMessageOptions();// Get the message off the queue.System.out.println("...and getting the message back again");queue.get(rcvMessage, gmo);// And display the message text...String msgText = rcvMessage.readUTF();System.out.println("The message is: " + msgText);// Close the queueSystem.out.println("Closing the queue");queue.close();// Disconnect from the QueueManagerSystem.out.println("Disconnecting from the Queue Manager");qMgr.disconnect();System.out.println("Done!");}catch (MQException ex) {System.out.println("A WebSphere MQ Error occured : Completion Code "+ ex.completionCode + " Reason Code " + ex.reasonCode);}catch (java.io.IOException ex) {System.out.println("An IOException occured whilst writing to the message buffer: "+ ex);}}}H

是字母.

设备型号： iPhone 6s Plus 序列号：F2MQMPCYGRWQ 激活状态：已激活 电话支持到期：2016-03-11 硬件保修到期：2016-12-11 硬件保修状态：未过期 硬件是否注册：已注册 生产工厂：中国 生产日期：2015-11-01 到 2015-11-07

indicator_buffers是显示的指标数组数量。IndicatorBuffers(2)是实际用到的指标数组数量。IndicatorBuffers(2)中包含indicator_buffers并且还包含过渡用的指标数组。IndicatorBuffers(2)要大于等于indicator_buffers的值。如果相等IndicatorBuffers(2)不写也可以。

1. 安装MQX4.0，在飞思卡尔官网把MQX的安装文件下载下来。2. 安装好之后会在安装目录下生成如下图所示的子目录。build目录：包含了飞思卡尔不同平台不同编译器的相关库的Makefile文件。具体内容如下列表示意图所示： build +---common | +---make ... shared Makefiles with global settings, variables and paths +--- ... board-specific folder | +---make ... folder contains mass-build Makefile for all libraries | +---tools ... tool-specific global settings, variables and paths | +---bsp ... BSP Library Makefile | +---psp ... PSP Library Makefile | +---mfs ... MFS Library Makefile | +---rtcs ... RTCS Library Makefile | +---shell ... Shell Library Makefile | +---usbd ... USB Device Library Makefile | +---usbh ... USB Host Library Makefile +--- +---make 3. 安装CodeWarrior Development Studio V10.5编译器。在飞思卡尔官网把CW10.5的安装文件下载下来。安装CW10.5时，请注意安装目录名称不要带空格。CW10.5的Cross_Tools目录已经自带了GNU GCC for ARM Cortex-M4内核的交叉编译工具链。4. 安装MinGW(Minimalist GNU on Windows) GNU工具集，在Windows下GNU GCC需要使用make.exe和sed.exe等工具。5. 上述软件安装完毕后，按照实际安装情况，修改编译MQX所需的交叉工具链的目录。1).修改全局宏定义脚本$MQX_DIRuildcommonmakeglobal.mak指定GNU 交叉工具链的安装路径TOOLCHAIN_ROOTDIR宏定义，如：TOOLCHAIN_ROOTDIR = C:/Freescale/CW10_52).指定编译某一硬件平台需要GNU GCC编译器的具体安装路径。如需要编译twrk60d00m这款Demo板，修改脚本文件$MQXuild wrk60d100mmake oolscw10gcc.mak，指定AS，CC，CX，AR，LD等工具的可执行文件。#------------------------------------------------------------# toolchain settings#------------------------------------------------------------AS = $(TOOLCHAIN_ROOTDIR)/Cross_Tools/arm-none-eabi-gcc-4_7_3/bin/arm-none-eabi-gcc.exe CC = $(TOOLCHAIN_ROOTDIR)/Cross_Tools/arm-none-eabi-gcc-4_7_3/bin/arm-none-eabi-gcc.exe CX = $(TOOLCHAIN_ROOTDIR)/Cross_Tools/arm-none-eabi-gcc-4_7_3/bin/arm-none-eabi-gcc.exe AR = $(TOOLCHAIN_ROOTDIR)/Cross_Tools/arm-none-eabi-gcc-4_7_3/bin/arm-none-eabi-ar.exe LD = $(TOOLCHAIN_ROOTDIR)/Cross_Tools/arm-none-eabi-gcc-4_7_3/bin/arm-none-eabi-gcc.exe6. 修改完毕上述脚本后，就可以开始使用GNU GCC编译MQX。在windows命令窗口下进入需要编译的目录,如Tower K60的编译目录：$MQXuild wrk60d100mmake。在命令行下输入make指令：C:FreescaleFreescale_MQX_4_0uild wrk60d100mmake>mingw32-make build TOOL=cw10gcc CONFIG=debug这条make指令能够将整个MQX进行编译，并生成bsp.a，psp.a，shell.a，rtcs.a，usbd.a，usbh.a等库文件。7. MQX系统库编译完毕后，可以进行应用程序的编译。在命令窗口进入需要编译的应用程序目录。如需要编译hello例程代码，进入$MQXmqxexampleshellomake目录，在命令下输入make命令：C:FreescaleFreescale_MQX_4_0mqxexampleshellomake>mingw32-make BOARD=twrk60d100m TOOL=cw10gcc CONFIG=debug LOAD=intflash buildGNU GCC将会编译应用程序代码，并与MQX的bsp.a，psp.a的库文件链接，生成.elf格式的可以执行文件。8. 下载调试.elf可执行文件。在CW10.5中New创建一个Bareboard Project工程，选择需要使用的下载调试器，并且选定使用GNU GCC作为编译器。在菜单Properties --> Run/Debug Setting中选择需要下载的目标文件。然后通过菜单Run-->Debug下载调试程序。

①、关于以上液晶电视电源芯片 MJP37R用什么芯片代换，能用 MQP37R替换吗？向以上原来的 “MJP37R” 完全可以用“MQP37R替换”，原因是，两款芯片是一样的，只是生产厂家不一样而已。

MQI：即公路技术状况指数（Highway Maintenance Quality Indicator），用于综合评价公路路基、路面、桥隧构造物和沿线设施技术状况的指标。公路技术状况指数MQI是《公路技术状况评定标准》（JTG 5210—2018）第2.0.1条规定的。MQI作为衡量判断公路技术状况的主要指标，辅以其分项指标，可对公路技术状况进行更为精确技术划分和路况判断。扩展资料：公路技术状况指数MQI和相应分项指标（路面使用性能指数PQI、路基技术状况指数SCI、桥隧构造物技术状况指数BCI、沿线设施技术状况指数TCI）将公路技术状况分为优、良、中、次、差五个等级。MQI及各级分项指标：≥90，属优；≥80但<90，属良；≥70但<80，属中；≥60但<70，属次；<60，属差。公路网公路技术状况评定时，应采用公路网内所有路线MQI的长度加权平均值作为该公路网的MQI。参考资料来源：湖北省交通运输厅黄黄高速公路管理处-黄黄管理处十三五规划报告参考资料来源：百度百科-高速公路

MQI：即公路技术状况指数（Highway Maintenance Quality Indicator），用于综合评价公路路基、路面、桥隧构造物和沿线设施技术状况的指标。公路技术状况指数MQI是《公路技术状况评定标准》（JTG 5210—2018）第2.0.1条规定的。MQI作为衡量判断公路技术状况的主要指标，辅以其分项指标，可对公路技术状况进行更为精确技术划分和路况判断。扩展资料：公路技术状况指数MQI和相应分项指标（路面使用性能指数PQI、路基技术状况指数SCI、桥隧构造物技术状况指数BCI、沿线设施技术状况指数TCI）将公路技术状况分为优、良、中、次、差五个等级。MQI及各级分项指标：≥90，属优；≥80但<90，属良；≥70但<80，属中；≥60但<70，属次；<60，属差。公路网公路技术状况评定时，应采用公路网内所有路线MQI的长度加权平均值作为该公路网的MQI。参考资料来源：湖北省交通运输厅黄黄高速公路管理处-黄黄管理处十三五规划报告参考资料来源：百度百科-高速公路

MQI：即公路技术状况指数（Highway Maintenance Quality Indicator），用于综合评价公路路基、路面、桥隧构造物和沿线设施技术状况的指标。公路技术状况指数MQI是《公路技术状况评定标准》（JTG 5210—2018）第2.0.1条规定的。MQI作为衡量判断公路技术状况的主要指标，辅以其分项指标，可对公路技术状况进行更为精确技术划分和路况判断。扩展资料：公路技术状况指数MQI和相应分项指标（路面使用性能指数PQI、路基技术状况指数SCI、桥隧构造物技术状况指数BCI、沿线设施技术状况指数TCI）将公路技术状况分为优、良、中、次、差五个等级。MQI及各级分项指标：≥90，属优；≥80但<90，属良；≥70但<80，属中；≥60但<70，属次；<60，属差。公路网公路技术状况评定时，应采用公路网内所有路线MQI的长度加权平均值作为该公路网的MQI。参考资料来源：湖北省交通运输厅黄黄高速公路管理处-黄黄管理处十三五规划报告参考资料来源：百度百科-高速公路

MQI：即公路技术状况指数（Highway Maintenance Quality Indicator），用于综合评价公路路基、路面、桥隧构造物和沿线设施技术状况的指标。公路技术状况指数MQI是《公路技术状况评定标准》（JTG 5210—2018）第2.0.1条规定的。MQI作为衡量判断公路技术状况的主要指标，辅以其分项指标，可对公路技术状况进行更为精确技术划分和路况判断。扩展资料：公路技术状况指数MQI和相应分项指标（路面使用性能指数PQI、路基技术状况指数SCI、桥隧构造物技术状况指数BCI、沿线设施技术状况指数TCI）将公路技术状况分为优、良、中、次、差五个等级。MQI及各级分项指标：≥90，属优；≥80但<90，属良；≥70但<80，属中；≥60但<70，属次；<60，属差。公路网公路技术状况评定时，应采用公路网内所有路线MQI的长度加权平均值作为该公路网的MQI。参考资料来源：湖北省交通运输厅黄黄高速公路管理处-黄黄管理处十三五规划报告参考资料来源：百度百科-高速公路

公路技术状况指数，MQI（Maintenance Quality Indicatior）是《公路技术状况评定标准》（JTG H20-2007）规定的，衡量判断公路技术状况的主要指标。辅以其分项指标，可对公路技术状况进行更为精确技术划分和路况判断。MQI的分项指标包括PQI、SCI、BCI、TCI，路面。扩展资料高速公路相关指标：湖北省高速公路养护代履行的实施意见 （试行）第七条出现下列情形之一的，由省高速公路管理局责令高速公路经营管理者限期整改，拒不整改的，由省高速公路管理局指定其他有资质的单位实施养护代履行：（一）未按规定频率落实定期检查的桥梁和隧道；（二）以单车道1公里为单位，技术状况指数（MQI）在90以下的路段；（三）以单车道1公里为单位，路面使用性能指数（PQI）在90以下的路段；（四）以单车道1公里为单位，路面行驶质量指数（RQI）在90以下的路段；（五）以单车道1公里为单位，路面损坏状况指数（PCI）在90以下的路段；（六）以单车道1公里为单位，路面车辙深度指数（RDI）在80以下的路段;（七）以单车道1公里为单位，路面抗滑性能指数（SRI）在80以下的路段；参考资料来源：湖北省交通运输厅黄黄高速公路管理处-黄黄管理处十三五规划报告参考资料来源：百度百科-湖北省高速公路养护代履行的实施意见 （试行）