java8 Stream 什么是 Stream？ Stream（流）是一个来自数据源的元素队列并支持聚合操作 元素是特定类型的对象，形成一个队列。 Java中的Stream并不会存储元素，而是按需计算。 流的来源。 可以是 集合 ， 数组 ， I/O channel ， 产生器generator 等 ...
分类：
编程语言 时间：
2019-11-17 11:05:35
阅读次数：
88
1 1 nio是什么？原理是什么？解决什么问题？如何实现？ 2 nio是nonblocked io 非堵塞流 3 核心类有 Channel/Selector/Buffer 4 解决高并发情况下流的阻塞问题 5 6 2.IO/NIO的区别，为什么要用NIO，使用IO中的Buffered..也能实现NI... ...
分类：
其他好文 时间：
2019-11-16 14:26:34
阅读次数：
126
直接使用go 函数名()可以开启一个grountine，channel可以接收信息并且如果没有数据时会阻塞住channel对应的是底层数据结构的引用，复制channel和函数传参都是拷贝的引用make的时候第二个参数是1，就表示是有缓存的channel 无缓存的channel也叫同步channel ...
分类：
其他好文 时间：
2019-11-16 14:26:21
阅读次数：
56
业务背景今日头条的服务大量使用微服务，容器数目巨大，业务线繁多，Topic的数量也非常多。另外，使用的语言比较繁杂，包括Python，Go,C++,Java,JS等，对于基础组件的接入，维护SDK的成本很高。引入RocketMQ之前采用的消息队列是NSQ和kafka，NSQ是纯内存的消息队列，缺少消息的持久性，不落盘直接写到Golang的channel里，在并发量高的时候CPU利用率非常高，其优点
分类：
其他好文 时间：
2019-11-15 20:26:28
阅读次数：
60
依赖jar包：jsch-0.1.55.jar commons-io-2.5.jar ...
分类：
编程语言 时间：
2019-11-15 18:20:29
阅读次数：
89
本文将通过JavaNIO实现文件的局域网发送功能。 目的： 1.为了体验零拷贝 2.为了体验NIO的Channel，Buffer，Selector 3.为了体验NIO方式网络传输文件和传统网络方式传输文件的差异（性能差异）。 什么是零拷贝： 那先来说说传统的文件传输：在本地读取文件（FileInpu ...
分类：
编程语言 时间：
2019-11-14 22:21:20
阅读次数：
75
消息手动确认模式的几点说明 监听的方法内部必须使用channel进行消息确认，包括消费成功或消费失败 如果不手动确认，也不抛出异常，消息不会自动重新推送（包括其他消费者），因为对于rabbitmq来说始终没有接收到消息消费是否成功的确认，并且Channel是在消费端有缓存的，没有断开连接 如果rab ...
分类：
其他好文 时间：
2019-11-14 00:15:26
阅读次数：
241
1.What’s your favorite sport?（你最喜欢什么运动?） 2.Football is my favorite.（足球是我最喜欢的。） 3.Which do you prefer,fishing or mountain climbing?（钓鱼和登山,你更喜欢哪一个?） 4.M ...
分类：
其他好文 时间：
2019-11-13 23:50:26
阅读次数：
161
使用场景 具体方法 注意：prefetchSize和global这两项，rabbitmq没有实现，暂且不做研究，prefetchCount在自动应答的情况下是不生效的，必须进行手动签收 创建生产者 channel.close(); connection.close(); 创建消费者 ...
分类：
其他好文 时间：
2019-11-11 09:19:43
阅读次数：
95
1.背景 java复制文件的方式其实有很多种,可以分为 传统的字节流读写复制FileInputStream,FileOutputStream,BufferedInputStream,BufferedOutputStream 传统的字符流读写复制FileReader,FileWriter,Buffer ...
分类：
编程语言 时间：
2019-11-09 20:02:59
阅读次数：
98
