1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

package main
 
import (
    "fmt"
    "math/rand"
    "time"
)
 
func main() {
    for {
        time.Sleep(time.Second * 3)
        fmt.Println(rand.Intn(128) + 1)
    }
 
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

package main
 
import (
    "fmt"
    "math/rand"
    "net/http"
    "strings"
    "time"
)
 
func main() {
 
    for {
        time.Sleep(time.Second * 3)
        i := rand.Intn(128) + 1
        fmt.Println(i)
        url := "http://host1:1210/bye" //请求地址
        contentType := "application/json"
        //参数，多个用&隔开
        data := strings.NewReader(fmt.Sprintf("%d", i))
        resp, _ := http.Post(url, contentType, data)
        fmt.Println(resp)
    }
 
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

package main
 
import (
    "fmt"
    "io/ioutil"
    "log"
    "net/http"
    "os"
    "time"
)
 
func main() {
    mux := http.NewServeMux()
    mux.HandleFunc("/bye", sayBye)
 
    server := &http.Server{
        Addr:         ":1210",
        WriteTimeout: time.Second * 3, //设置3秒的写超时
        Handler:      mux,
    }
    log.Println("Starting v3 httpserver")
    log.Fatal(server.ListenAndServe())
}
 
func sayBye(w http.ResponseWriter, r *http.Request) {
    str, _ := readBodyAsString(w, r)
    fmt.Println(str)
    currentPath, _ := os.Getwd()
    //这里要自己建一个context.txt文件
    appendToFile(currentPath+"/context.txt", str+"\n")
}
 
func readBodyAsString(writer http.ResponseWriter, request *http.Request) (string, error) {
    defer request.Body.Close()
    body, err := ioutil.ReadAll(request.Body)
    if err != nil {
        return "", err
    }
 
    if len(body) == 0 {
        return "", fmt.Errorf("no request body provided")
    }
 
    return string(body), nil
}
 
func appendToFile(fileName string, content string) error {
    // 以只写的模式，打开文件
    f, err := os.OpenFile(fileName, os.O_WRONLY, 0644)
    if err != nil {
        fmt.Println("cacheFileList.yml file create failed. err: " + err.Error())
    } else {
        // 查找文件末尾的偏移量
        n, _ := f.Seek(0, os.SEEK_END)
        // 从末尾的偏移量开始写入内容
        _, err = f.WriteAt([]byte(content), n)
    }
    defer f.Close()
    return err
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

name: "rand-numeric" #旧的值是 sample-numeric
manufacturer: "Intel Corp."
model: "Some 3rd party App sending int & floats"
labels:
 - "rest"
 - "float64"
 - "int64"
description: "REST Device that sends in ints and floats"

deviceResources:
  - name: int
    description: "Int64 value"
    properties:
      value:
        { type: "Int64", readWrite: "W" , mediaType : "application/json" } #旧的值是 text/plain, 写成json的原因是我们设备上传的数据使用json头，我没有尝试不一样会怎么样， 反正我是改了
      units:
        { type: "String", readWrite: "R"}
  - name: float
    description: "Float64 value"
    properties:
      value:
        { type: "Float64", readWrite: "W" , mediaType : "text/plain" }
      units:
        { type: "String", readWrite: "R" }

deviceCommands:
  - name: PostInt
    get:
      - { operation: "get", deviceResource: "int"}
  - name: PostFloat
    get:
      - { operation: "get", deviceResource: "float"}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21

name: "rand-numeric"
manufacturer: "Intel Corp."
model: "Some 3rd party App sending int & floats"
labels:
 - "rest"
 - "int64"
description: "REST Device that sends in ints and floats"
 
deviceResources:
  - name: int
    description: "Int64 value"
    properties:
      value:
        { type: "Int64", readWrite: "W" , mediaType : "application/json" }
      units:
        { type: "String", readWrite: "R"}
 
deviceCommands:
  - name: PostInt
    get:
      - { operation: "get", deviceResource: "int"}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

func main() {
 
    for {
        time.Sleep(time.Second * 3)
        i := rand.Intn(128) + 1
        fmt.Println(i)
        url := "http://host3:49986/api/v1/resource/rand-numeric/int" //请求地址
        contentType := "application/json"
        //参数，多个用&隔开
        data := strings.NewReader(fmt.Sprintf("%d", i))
        resp, _ := http.Post(url, contentType, data)
        fmt.Println(resp)
    }
 
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

func deviceHandler(writer http.ResponseWriter, request *http.Request) {
    handler, ok := request.Context().Value(handlerContextKey).(RestHandler)
    if !ok {
        writer.WriteHeader(http.StatusBadRequest)
        writer.Write([]byte("Bad context pass to handler"))
        return
    }

    handler.processAsyncRequest(writer, request)
    resStr := "success"
    writer.Write([]byte(resStr))
}

1
2
3
4
5
6
7
8

asyncValues := &models.AsyncValues{
    DeviceName:    deviceName,
    CommandValues: []*models.CommandValue{value},
}

handler.logger.Debug(fmt.Sprintf("Incoming reading received: Device=%s Resource=%s", deviceName, resourceName))

handler.asyncValues <- asyncValues