主页 / user-347034

Андрей Алексеев's questions

Martin Hope
Андрей Алексеев
Asked: 2024-10-10 13:23:50 +0000 UTC
  • 5

是的map，或者更确切地说map[string]int

默认情况下，据我了解，Golang它按字母顺序按键对元素进行排序。如何map按给定顺序按键排序？

这段代码：

package main

import (
    "fmt"
)

func main() {
    output := make(map[string]int)

    basket := map[string]int{
        "orange": 5, 
        "apple": 7,
        "mango": 3,
        "strawberry": 9,
    }

    //нужный порядок
    keys := []string{
        "strawberry",
        "mango",
        "orange",
    }

    for _, k := range keys {
        output[k] = basket[k]
    }

    fmt.Printf("вывод output : %+v \n", output)
}

将生成带有按字母顺序排列的键的行：

mango, orange, strawberry
golang
Martin Hope
Андрей Алексеев
Asked: 2022-06-29 21:33:20 +0000 UTC
  • 0

我在 docker 容器中运行服务以及 kafka 和 zookeeper。

我启动了 akhq 服务，它就像一个用于查看 kafka 主题和消息的面板。

akhq 服务显示创建的主题和 kafka 消息。此服务在 kafka:9092 连接

但是另一项服务 adapter 无法连接到 kafka。出现错误：拨打 tcp :9092: 连接：连接被拒绝

虽然适配器服务也尝试连接到 kafka:9092 ，（尝试了 127.0.0.1:9092 和 localhost:9092）从适配器服务的控制台，地址 kafka:9092 被成功 ping。

我该如何解决？

我正在附加 docker-compose.yaml

version: '3'

volumes:
  zookeeper-data:
    driver: local
  zookeeper-log:
    driver: local
  kafka-data:
    driver: local

services:
    akhq:
        image: tchiotludo/akhq
        environment: 
          AKHQ_CONFIGURATION: |
            akhq:
              security:
                default-group: reader
              connections:
                docker-kafka-server:
                  properties:
                    bootstrap.servers: "kafka:9092"
                  schema-registry:
                    url: "http://schema-registry:8085"

        ports:
          - 8888:8080
        links:
          - kafka
          - schema-registry

    zookeeper:
        image: confluentinc/cp-zookeeper
        volumes:
          - zookeeper-data:/var/lib/zookeeper/data:Z
          - zookeeper-log:/var/lib/zookeeper/log:Z
        environment:
          ZOOKEEPER_CLIENT_PORT: '2181'
          ZOOKEEPER_ADMIN_ENABLE_SERVER: 'false'

    kafka:
        image: confluentinc/cp-kafka
        volumes:
          - kafka-data:/var/lib/kafka/data:Z
        environment:
          KAFKA_BROKER_ID: '0'
          KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
          KAFKA_NUM_PARTITIONS: '12'
          KAFKA_COMPRESSION_TYPE: 'gzip'
          KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: '1'
          KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: '1'
          KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: '1'
          KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT://kafka:9092'
          KAFKA_CONFLUENT_SUPPORT_METRICS_ENABLE: 'false'
          KAFKA_JMX_PORT: '9091'
          KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'true'
          KAFKA_AUTHORIZER_CLASS_NAME: 'kafka.security.authorizer.AclAuthorizer'
          KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND: 'true'
        links:
          - zookeeper

    schema-registry:
        image: confluentinc/cp-schema-registry
        depends_on:
          - kafka
        environment:
          SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: 'PLAINTEXT://kafka:9092'
          SCHEMA_REGISTRY_HOST_NAME: 'schema-registry'
          SCHEMA_REGISTRY_LISTENERS: 'http://0.0.0.0:8085'
          SCHEMA_REGISTRY_LOG4J_ROOT_LOGLEVEL: 'INFO'


    adapter: #kafka adapter
        build:
            context: .
            dockerfile: ./adapter.dockerfile
        environment:
            - GO_ENV=dev
            - GOPATH=/go
        container_name: kafka-adapter-app
        depends_on:
          - kafka

docker
Martin Hope
Андрей Алексеев
Asked: 2022-05-19 19:14:13 +0000 UTC
  • 1

当使用这样的代码从 post 请求的正文中解码 json 时，出现解码错误。此外，从错误的文本来看，错误不在这个方法中，而在 h(w, r) 方法后面的 graphql 处理程序中。

func middlewareAuth(h http.HandlerFunc) http.HandlerFunc {
  return func(w http.ResponseWriter, r *http.Request) {

    var requestBody requestBody

    bytebody, err := ioutil.ReadAll(r.Body)
    if err != nil {
        w.WriteHeader(http.StatusBadRequest)
        http.Error(w, "{\"errors\":[{\"message\":\"Request decode error!.\"}],\"data\":null}", 400)
        return
    }

    replaceChars := strings.NewReplacer("\n", "", "\r", "")
    strbody := replaceChars.Replace(string(bytebody))

    if len(strbody) > 0 {
        err := json.Unmarshal([]byte(strbody), &requestBody)
        if err != nil {
            w.WriteHeader(http.StatusBadRequest)
            http.Error(w, "{\"errors\":[{\"message\":\"Request decode error! please check your JSON formating. custom\"}],\"data\":null}", 400)
            return
        }
    }

    h(w, r)
  }
}

graphql 抛出错误：

{
  "error": {
    "errors": [
      {
        "message": "json body could not be decoded: EOF"
      }
    ],
    "data": null
  }
}

但是如果你在一个字符串中处理任意json，那么就没有错误：

func middlewareAuth(h http.HandlerFunc) http.HandlerFunc {
  return func(w http.ResponseWriter, r *http.Request) {

    var requestBody requestBody

    var strbody string
    strbody = "{\"query\":\"custom\", \"token\":\"l7k8\"}"


    if len(strbody) > 0 {
        err := json.Unmarshal([]byte(strbody), &requestBody)
        if err != nil {
            w.WriteHeader(http.StatusBadRequest)
            http.Error(w, "{\"errors\":[{\"message\":\"Request decode error! please check your JSON formating. custom\"}],\"data\":null}", 400)
            return
        }
    }

    h(w, r)
  }
}

我不明白为什么会发生错误，我没有修改请求

帮助修复错误

json