cdliqing.com

rockybean.info

Jafka Broker代码阅读之总览 - Rockybean

http://rockybean.info/2012/08/01/jafka-src

August 1, 2012. Properties props = new Properties(); props.setProperty("port","9093"); props.setProperty("log.dir","/home/alfred/jafkaDataDirs/data1"); Jafka broker = new Jafka(); broker.start(props,null,null); broker.awaitShutdown();. Jafka broker在正常关闭的时候会在数据文件夹下生成一个.jafka cleanshutdown的文件,broker 在启动时可以通过检查该文件是否存在来判定上一次broker是否为正常关闭，如果不是正常关闭，那么jafka在打开每个topic-partition文件夹下最后一个jafka文件时会去校验其消息数据 即jafka文件 ，如果发现其上某条消息的实际长度不等于消息头中指定的长度，说明该消息有问题，则删除它及其以后的消息数据。 Src main assembly #maven assembly插件配置文件 java com ...

rockybean.info

tcp自连接问题 - Rockybean

http://rockybean.info/2014/11/29/tcp_self_connection

November 29, 2014. Import socket import time connected=False while (not connected): try: sock = socket.socket(socket.AF INET,socket.SOCK STREAM) sock.setsockopt(socket.IPPROTO TCP,socket.TCP NODELAY,1) sock.connect( '127.0.0.1',55555) connected=True except socket.error,(value,message): print message if not connected: print "reconnect" print "tcp self connection occurs! Print "try to run follow command : " print "netstat -an grep 55555" time.sleep(1800). Netipv4.ip local port range. Nginx 的 tcp 的链接问题.

rockybean.info

Rockybean

http://rockybean.info/page/4

August 30, 2014. Tcpdump -nn port 12345. August 11, 2014. August 6, 2014. August 4, 2014. July 6, 2014. 这段socketServer 代码 跟cobar 中间件的代码 .

rockybean.info

Producer使用示例与配置简要说明 - Rockybean

http://rockybean.info/2012/07/23/jafka-producer

July 23, 2012. Properties props = new Properties(); / 指明获取发送地点的地址 props.setProperty("zk.connect","localhost:2181"); props.setProperty("serializer.class", StringEncoder.class.getName() ; Producer String,String producer = new Producer String, String (new ProducerConfig(props) ; for(int i=0;i 1000;i ){ / 构造消息并发送 producer.send(new StringProducerData("hehe","hehe-data" i) ; } producer.close();. Class ProducerData K, V { private String topic; private K key; private List V data; . }. June 30th, 2015 at 02:41 pm.

rockybean.info

Rockybean

http://rockybean.info/page/2

February 1, 2015. January 19, 2015. Ssh:Permission denied public key. January 2, 2015. November 29, 2014. November 24, 2014. 这段socketServer 代码 跟cobar 中间件的代码 .

rockybean.info

名词解释之PDU - Rockybean

http://rockybean.info/2015/01/02/pdu

January 2, 2015. 这段socketServer 代码 跟cobar 中间件的代码 .

rockybean.info

Jafka Broker源码阅读之SocketServer解析 - Rockybean

http://rockybean.info/2012/08/02/jafka-broker-socketserver

August 2, 2012. Public void startup() throws InterruptedException { / 每个processor可以处理的最大连接数 final int maxCacheConnectionPerThread = serverConfig.getMaxConnections() / processors.length; logger.info("start " processors.length " Processor threads"); / 初始化并启动所有的Processor线程，其数目默认为cpu个数，可以通过num.threads来配置 for (int i = 0; i processors.length; i ) { processors[i] = new Processor(handlerFactory, stats, maxRequestSize, maxCacheConnectionPerThread); Utils.newThread("jafka-processor-" i,...Private void accept(Selec...

rockybean.info

Rockybean

http://rockybean.info/page/8

July 24, 2012. July 23, 2012. 这段socketServer 代码 跟cobar 中间件的代码 .

rockybean.info

rockybean 发布的文章 - Rockybean

http://rockybean.info/author/1

May 24, 2016. April 13, 2015. February 27, 2015. February 25, 2015. February 9, 2015. 这段socketServer 代码 跟cobar 中间件的代码 .