Как ответить на принятое соединение в нац. Подписаться на голанг - PullRequest
Новая
       25

Как ответить на принятое соединение в нац. Подписаться на голанг

0 голосов
/ 11 сентября 2018

Я пытаюсь создать tcp сервер в golang, который принимает соединение, читает данные и затем публикует их через nats.Publish.Но я также хочу ответить и закрыть соединение внутри подписчика, а не в сценарии основного сервера. Я вижу два возможных способа: опубликовать соединение или создать новое в подписчике, но я также не могу понять, спасибо заранее

UPD Комментарий относительно ответа И. Козловича: Не совсем то, что я хотел, но могу помочь :) Я писал о закрытии соединения tcp - не nats, а о закрытии в другом процессе go - не в том, который был принят.Но так как мне это не удалось, я мог бы сделать следующее на основе вашего ответа: я могу опубликовать нужную мне информацию через nats, обработать ее, а затем ответить «ОК. Закрыть соединение» и закрыть TCP-соединение в издателе, который является TCPсервер.Однако было бы здорово, если бы я мог ответить не из этого процесса, а из другого.Это сложно, я понимаю, но я хочу сделать то же, что я написал в предыдущем сообщении, но с некоторыми изменениями.У меня есть TCP-сервер, он принимает соединение, а затем подключает nats и публикует сообщение, другой процесс go, подписанный на это сообщение, обрабатывает ввод, а затем публикует свои выходные данные в третьем процессе go, который обрабатывает его ввод и затем отвечает «ОК. Готово. Закройте TCP-соединение"к первому ходу процесса ....:)

1 Ответ

0 голосов
/ 28 сентября 2018

Исходя из вашего обновленного вопроса, здесь возможный подход.Обратите внимание, что здесь два дополнительных процесса представлены подпрограммами, но в реальном случае они будут отдельными процессами.Я также пропустил проверку ошибок. 

// This represent what would be the last process in your
// example.
go func() {
    nc, _ := nats.Connect(nats.DefaultURL)
    nc.Subscribe("bar", func(m *nats.Msg) {
        fmt.Printf("Received request: %s, final stop, sending back to %v\n", m.Data, m.Reply)
        nc.Publish(m.Reply, []byte("I'm here to help!"))
    })
    nc.Flush()
    runtime.Goexit()
}()

// This would be the in-between process that receives
// the message triggered by the TCP accept
go func() {
    nc, _ := nats.Connect(nats.DefaultURL)
    nc.Subscribe("foo", func(m *nats.Msg) {
        fmt.Printf("Received request: %s, forward to bar\n", m.Data)
        nc.PublishRequest("bar", m.Reply, []byte(fmt.Sprintf("got %s", m.Data)))
    })
    nc.Flush()
    runtime.Goexit()
}()

// This would be your TCP server
l, _ := net.Listen("tcp", "127.0.0.1:1234")
for {
    c, _ := l.Accept()
    go func(c net.Conn) {
        // Close socket when done
        defer c.Close()
        // Connect to NATS
        nc, _ := nats.Connect(nats.DefaultURL)
        // Close NATS connection when done
        defer nc.Close()
        // Sends the request to first process. Note that this
        // has a timeout and so if no response is received, the
        // go-routine will exit, closing the TCP connection.
        reply, err := nc.Request("foo", []byte("help"), 10*time.Second)
        if err != nil {
            fmt.Printf("Got error: %v\n", err)
        } else {
            fmt.Printf("Got reply: %s\n", reply.Data)
        }
    }(c)
}

Обратите внимание, что обычно не рекомендуется создавать соединения NATS с очень коротким сроком службы.Возможно, вы захотите повторно использовать соединение NATS, если оно соответствует вашей модели.

...