Server端代码： 1 package com.helloworld; 2 3 import java.io.IOException; 4 5 import com.rabbitmq.client.Channel; 6 import com.rabbitmq.client.Connection.....
分类：
其他好文 时间：
2014-10-20 00:41:44
阅读次数：
278
写入hdfsa1.channels.c1.type = memory# Define an Avro source called r1 on a1 and tell it# to bind to 0.0.0.0:41414. Connect it to channel c1.a1.sources.r...
分类：
Web程序 时间：
2014-10-18 00:33:46
阅读次数：
273
磁盘阵列被越来越多地使用到各种应用系统中，开始只是简单地作为某台主机或服务器的附加外置存储设备，主要用于扩展单台主机或服务器的永久存储空 间，一般通过SCSI或其它接口与主机直接相连；后来随着存储网络技术，尤其是光纤通道（Fibre Channel）技术的发展，磁盘阵列通过光纤通道接口接入到存储区域...
分类：
其他好文 时间：
2014-10-15 23:17:41
阅读次数：
260
{dede:channelartlist row='2' typeid='1,2' }{dede:field name='typename'/}{dede:channel type='son' noself='yes' }[field:typename/]{/dede:channel}{/dede:...
分类：
其他好文 时间：
2014-10-12 00:21:16
阅读次数：
266
一、概述
1、现在有三台机器，分别是：Hadoop1，Hadoop2，Hadoop3，以Hadoop1为日志汇总
2、Hadoop1汇总的同时往多个目标进行输出
3、Flume一个数据源对应多个channel，多个sink，是在consolidation-accepter.conf文件里配置的
二、部署Flume来采集日志和汇总日志
1、在Hadoop1上运行fl...
分类：
Web程序 时间：
2014-10-10 17:10:34
阅读次数：
568
channel会阻塞，阻塞的时候系统会继续顺序调用其他goroutine，main()也是一个goroutine，只是最先被执行。 看一个代码： package main import ( "fmt" ) func display(msg string, c chan bool) { fmt.Println(ms...
分类：
其他好文 时间：
2014-10-09 13:26:08
阅读次数：
169
以下是接口xml格式数据： rss xmlns:yweather="http://xml.weather.yahoo.com/ns/rss/1.0" xmlns:geo="http://www.w3.org/2003/01/geo/wgs84_pos#" version="2.0">
channel>
title>Yahoo! Weather - Beijing, CNtitle>
lin...
分类：
编程语言 时间：
2014-10-07 17:54:03
阅读次数：
338
Go语言中的内建函数new和make是两个用于内存分配的原语（allocation primitives）。对于初学者，这两者的区别也挺容易让人迷糊的。简单的说，new只分配内存，make用于slice，map，和channel的初始化。
分类：
其他好文 时间：
2014-10-03 15:14:44
阅读次数：
206
“网络，并发”是Go语言的两大feature。Go语言号称“互联网的C语言”，与使用传统的C语言相比，写一个Server所使用的代码更少，也更简单。写一个Server除了网络，另外就是并发，相对python等其它语言，Go对并发支持使得它有更好的性能。
Goroutine和channel是Go在“...
分类：
其他好文 时间：
2014-10-02 02:15:12
阅读次数：
250
golang并没有在语言层次上提供超时操作，但可以通过一些小技巧实现超时。 原理： 并发一个函数，等待1s后向timeout写入数据，在select中如果1s之内有数据向其他channel写入则会顺利执行，如果没有，这是timeout写...
分类：
其他好文 时间：
2014-10-01 13:55:31
阅读次数：
150
