Page page=new Page(param.getCurrent(),param.getSize());Wrapper w= new EntityWrapper();w.eq("trade_type",tradeType); //支付类型w.eq("check_result",checkResult); //对账结果...

1 查看进程占用的端口[root@localhost ~]# netstat -nap | grep 126012tcp6       0      0 :::8001                 :::*                    LISTEN      126012/java         tcp6       0      0 10.26.20.68:42674  ...

Kafka采用拉取（Pull）方式消费消息，吞吐量相对更高，适用于海量数据收集与传递场景，例如日志采集和集中分析。RabbitMQ在吞吐量方面略有逊色，但支持更多的消息队列功能。RocketMQ出自 阿里公司的开源产品，用 Java 语言实现，在设计时参考了 Kafka，并做出了自己的一些改进。在阿里集团被广泛应用在订单，交易，充值，流计算，消息推送，日志流式处理，binglog分发等场景。以下从

架构运行过程：在需要采集日志的服务上部署filebeat，filebeat将采集到的数据output到kafka，logstash在kafka上消费数据进行转换，output数据到elasticsearch，进行数据搜索和分析，kibana对elasticsearch中数据做可视化。...

一、IO基础原理1、操作系统的IO应用程序进行IO的读写，依赖于底层操作系统的IO读写，是通过操作系统的两大系统调用read、write来实现的。应用程序调用操作系统的read、write接口，完成数据在应用程序的进程缓冲区和操作系统的内核缓冲区之间的交互。操作系统设置数据缓冲区的目的，是为了提升性能。外部设备的直接读写，涉及操作系统的中断。发生系统中断时，需要保存之前的进程数据和状态等信息，而结

dwr-invoker   org.directwebremoting.servlet.DwrServlet      debug    true     1   dwr-invoker   /dwr/*我们注意到它里面包含了这段配置：1，那么这个配置有什么作用呢？贴一段英文原汁原味的解释如下：Servlet specificat

衡量分布式统计算法的指标有3个：数据量、实时性和精准性。任何算法只能满足其中2个指标，ES为了数据的实时性，降低了聚合分析的精准性。由于ES的数据是分布在各个分片上的，coordinating节点无法获取数据的概览，ES提供了一个参数返回遗漏的term分组上的文档数，这个值越小精准度越高，为0表示结果是精准的。为了让统计数据是精准的，有两种方式：1 当数据量较少时，只设置一个分片；2 增加shar

为什么在RocketMQ和kafka中选型在单机同步发送的场景下，Kafka>RocketMQ，Kafka的吞吐量高达17.3w/s，RocketMQ吞吐量在11.6w/s。kafka高性能原因生产者Kafka会把收到的消息都写入到硬盘中，它绝对不会丢失数据。为了优化写入速度Kafak采用了两个技术，顺序写入和MMFile。顺序写入因为硬盘是机械结构，每次读写都会寻址->写入，其中寻址