V2EX › jarlyyn 的所有回复 › 第 19 页 / 共 279 页

如果我写可能是这样？

var asyncProducer *sarama.AsyncProducer
var cmd *exec.cmd
var quit make (chan int)
var stdout io.ReadCloser
var stderr io.ReadCloser
var outputs make(chan string,10)
func main(){
initProducer()
defer asyncProducer.Close()
initCmd()
initStdout()
defer stdout.close()
pipeMessage(stdout,outputs)
initStderr()
defer stderr.close()
pipeMessage(stderr,outputs)
for{
select{
case quit:
return
case newline:= <- outputs :
asyncProducer.Input() <-&sarama.ProducerMessage{
Topic: "test",
Value: sarama.ByteEncoder(newline),
}
case err := <-asyncProducer.Errors():
fmt.Println("kafka error")
case <-asyncProducer.Successes():
}
}

}
func initProducer(){
config := sarama.NewConfig()
config.Producer.Return.Successes = true
config.Producer.RequiredAcks = sarama.WaitForAll
p, err := sarama.NewAsyncProducer(strings.Split("192.168.1.1:9092", ","), config)
if err != nil {
fmt.Println("kafka failed")
panic(err)
}
asyncProducer = &p

}
func initCmd(){
cmd := exec.Command("/fabio", "-cfg", "/etc/fabio/fabio.properties")
fmt.Println(cmd.Args)
go func(){
defer close(quit)
err:=cmd.Run()
if err!=nil{
panic(err)
}
}
}

func initStdout(){
stdout, err := cmd.StdoutPipe()
if err != nil {
panic(err)
}
}
func initStderr(){
stderr, err := cmd.StderrPipe()
if err != nil {
panic(err)
}
}
func pipeMessage(reader io.ReadCloser,output chan string){
reader := bufio.NewReader(readCloser)
go func(){
for {
line, err2 := reader.ReadString('\n')
if err2 != nil || io.EOF == err2 {
break
}
fmt.Print(line)
output <- line
}
}
}

2017-07-18 02:13:14 +08:00

回复了 yuanfnadi 创建的主题 › Go 编程语言 › Go 初学者想要 V 友帮忙看一下代码

看得我一愣一愣的。特别是这么多 go。

对你用的工具不熟悉。

但是不明白你为什么起这么多协程。

如果是我的话，首先不会写这个 gerProducer，初始化的时候直接初始化不就好了么。没看出来它啥时候会变 nil。

其次感觉你是为了尽可能快的异步读日志再转写？

那感觉开一个 message 的 chan,设一个恰当的缓存大小。

然后 fabio 那里 go 两个协程出来写入 chan

sendMessage 那里 go 个写成出来读 chan,感觉更符合调理一些。

个人 YY，对你这个业务不熟。

另外，按你这个写法是不是要维护个链接池？

不然连接数容易炸吧？

2017-07-17 19:11:57 +08:00

回复了 holinhot 创建的主题 › PHP › PHP 框架 laravel 和 phalcon 性能怎么差了 10 几倍

把核心功能换个其他的高并发语言比如 go 做个接口？

2017-07-17 18:48:32 +08:00

回复了 gavinczhang 创建的主题 › PHP › 对主流框架不感冒，想开发属于自己的框架，寻求不同见解或同好朋友

做框架很正常啊，一般用着用着就有需求做框架了。

但自己写框架不是应该是流行框架有和自己的业务流程不符的地方，或者不想被流行框架的版本升级绑架么……

也就是不是流行有缺点。

而是自己做框架能解决痛点……

2017-07-17 17:11:54 +08:00

回复了 whileFalse 创建的主题 › 问与答 › 七牛的文件存储简直是弱智

@whileFalse

你取的到底是 cdn 还是文件存储？

2017-07-17 17:02:18 +08:00

回复了 holinhot 创建的主题 › PHP › PHP 框架 laravel 和 phalcon 性能怎么差了 10 几倍

说句可能不爱听的。

既然你选择在这个部分用 php。

那说明你这个部分并发并没有那么重要。