2015-03-25 22 views
2

我有以下代码,我正在使用RESTful框架的Go,叫做sleepy使用Gobot.io和昏昏沉沉的RESTful Framework执行SparkCore函数

我可以成功启动该服务:http://localhost:3000,但是当我尝试访问http://localhost:3000/temperature时,我期待我的SparkCore函数dht执行。

我正在使用Gobot.io Spark platform来执行此功能,它基于我在自己的代码中实现的this example

问题是代码没有通过Get()函数中的gobot.Start()方法,所以我实际上不能返回result数据。

我设置data值希望我可以做:

return 200, data, http.Header{"Content-type": {"application/json"}} 

但它从来没有被调用监守的gobot.Start()的。

我很新,所以任何帮助将不胜感激。

package main 

import (
    "net/url" 
    "net/http" 
    "fmt" 
    "github.com/dougblack/sleepy" 
    "github.com/hybridgroup/gobot" 
    "github.com/hybridgroup/gobot/platforms/spark" 
) 

var gbot = gobot.NewGobot() 
var sparkCore = spark.NewSparkCoreAdaptor("spark", "device_id", "auth_token") 

type Temperature struct {} 
func (temperature Temperature) Get(values url.Values, headers http.Header) (int, interface{}, http.Header) { 
    work := func() { 
     if result, err := sparkCore.Function("dht", ""); err != nil { 
      fmt.Println(err) 
     } else { 
      data := map[string]string{"Temperature": result} 
      fmt.Println("result from \"dht\":", result) 
     } 
    } 

    robot := gobot.NewRobot("spark", 
     []gobot.Connection{sparkCore}, 
     work, 
    ) 

    gbot.AddRobot(robot) 
    gbot.Start() 

    return 200, data, http.Header{"Content-type": {"application/json"}} 
} 

func main() { 
    api := sleepy.NewAPI() 

    temperatureResource := new(Temperature) 
    api.AddResource(temperatureResource, "/temperature") 

    fmt.Println("Listening on http://localhost:3000/") 
    api.Start(3000) 
} 

回答

2

gbot.Start()是一个阻塞呼叫。

在这种情况下,您预计称其为:

go gbot.Start() 

这将启动它在一个够程(认为线程),然后让你的应用程序继续。

当你看着gobot example app,它们不会在后台运行,因为它是主要功能。如果main在后台运行所有内容,并且没有等待任何内容,则应用程序会立即退出并且没有任何明显效果。

+1

我的部分的排字错误,gbot.Start(),只是在阻止的行前添加单词go ...更新答案 – 2015-03-26 02:36:07