access_token, ok := result["access_token"] if !ok { fmt.Println("access_token not found") return } // access_token = "bearer " + access_token newJson := map[string]interface{}{ "token": access_token, }上面的go语言代码中access_token前面加"bearer"并保存文件

你可以使用以下代码将access_token前面加上"bearer"并保存到文件中：

access_token, ok := result["access_token"]
if !ok {
fmt.Println("access_token not found")
return
}
// add "bearer " to the beginning of the access_token
access_token = "bearer " + access_token.(string)
// create a map to hold the new JSON data
newJson := map[string]interface{}{
"token": access_token,
}
// convert the map to a JSON string
newJsonBytes, _ := json.Marshal(newJson)
newJsonString := string(newJsonBytes)
// write the JSON string to a file
err := ioutil.WriteFile("new.json", []byte(newJsonString), 0644)
if err != nil {
fmt.Println("error writing file: ", err)
return
}

相关问题

用go语言提取{"access_token":"hy.patrol.1.a1b421bb-46fd-4460-bddf-777eaefc68b4","token_type":"bearer","refresh_token":"hy.patrol.1.d669276c-446c-4654-9f12-837a9af1bb33","expires_in":3558,"scope":"all","user_info":{"username":"H02110"}}中的"access_token":"hy.patrol.1.a1b421bb-46fd-4460-bddf-777eaefc68b4"并保持成json

代码实现：

package main

import (
	"encoding/json"
	"fmt"
)

func main() {
	originalJson := `{"access_token":"hy.patrol.1.a1b421bb-46fd-4460-bddf-777eaefc68b4","token_type":"bearer","refresh_token":"hy.patrol.1.d669276c-446c-4654-9f12-837a9af1bb33","expires_in":3558,"scope":"all","user_info":{"username":"H02110"}}`

	var result map[string]interface{}
	err := json.Unmarshal([]byte(originalJson), &result)
	if err != nil {
		fmt.Println("Unmarshal error:", err)
		return
	}

	access_token, ok := result["access_token"]
	if !ok {
		fmt.Println("access_token not found")
		return
	}

	newJson := map[string]interface{}{
		"access_token": access_token,
	}

	newBytes, err := json.Marshal(newJson)
	if err != nil {
		fmt.Println("Marshal error:", err)
		return
	}

	fmt.Println(string(newBytes))
}

输出结果：

{"access_token":"hy.patrol.1.a1b421bb-46fd-4460-bddf-777eaefc68b4"}

package main import ( "fmt" "log" "os" "time" "github.com/goburrow/modbus" "github.com/tarm/serial" MQTT "github.com/eclipse/paho.mqtt.golang" ) // 定义回调函数，处理订阅的消息 var f MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { fmt.Printf("TOPIC: %s\n", msg.Topic()) fmt.Printf("MSG: %s\n", msg.Payload()) } func main() { // 创建新的客户端 opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883") opts.SetClientID("golang-client") opts.SetDefaultPublishHandler(f) c := MQTT.NewClient(opts) if token := c.Connect(); token.Wait() && token.Error() != nil { panic(token.Error()) } // 订阅主题 if token := c.Subscribe("golang/topic", 0, nil); token.Wait() && token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } // 连接串口 c := &serial.Config{Name: "/dev/ttyS0", Baud: 115200} s, err := serial.OpenPort(c) if err != nil { log.Fatal(err) } // 创建 Modbus 从机实例 handler := modbus.NewRTUClientHandler(s) handler.BaudRate = 115200 handler.DataBits = 8 handler.Parity = "N" handler.StopBits = 1 handler.SlaveId = 1 handler.Timeout = 5 * time.Second defer handler.Close() client := modbus.NewClient(handler) // 读取寄存器 results, err := client.ReadHoldingRegisters(1, 2) if err != nil { log.Fatal(err) } fmt.Println(results) // 输出读取到的寄存器值 // 设置寄存器 err = client.WriteMultipleRegisters(1, 2, []byte{0x01, 0x02}) if err != nil { log.Fatal(err) } // 发布消息 for i := 0; i < 5; i++ { text := fmt.Sprintf("this is msg #%d!", i) token := c.Publish("golang/topic", 0, false, text) token.Wait() } time.Sleep(3 * time.Second) // 断开连接 if token := c.Unsubscribe("golang/topic"); token.Wait() && token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } c.Disconnect(250) }

这是一段 Go 语言程序，在这段程序中，包含了多个包的导入，包括 fmt、log、os、time、modbus 和 serial。它还引入了 paho.mqtt.golang 包，用于处理 MQTT 协议相关的功能。

在 main 函数中，定义了一个名为 f 的 MQTT.MessageHandler 类型的变量，这个变量是一个匿名函数，用于处理订阅的消息。

接下来，程序创建了一个新的 MQTT 客户端，并设置了客户端的 ID 和默认的发布处理函数。然后，程序尝试连接到本地的 MQTT 服务器，并在连接成功之后执行相关操作。