Как общаться между контекстами ZeroMQ в разных программах?

Question

Я использую это как шаблон, за исключением того, что в той же программе у меня также есть некоторые рабочие программы, которые являются рабочими и подключаются к конечной точке бэкэнда, tcp://127.0.0.1:5560.

То, что я хотел бы сделать, это подключить его более эффективным способом, таким как ipc: //, inproc: // или даже сокеты unix. Я пробовал это, и это не сработало. Каналы не нужны с ZeroMQ, верно?

Итак, как мне соединить различные программы с контекстами ZeroMQ без tcp? Есть ли лучшая альтернатива?

обновление: код:

// Simple message queuing broker
// Same as request-reply broker but using QUEUE device
//
// Author:  Brendan Mc.
// Requires: http://github.com/alecthomas/gozmq

package main

import (
    zmq "github.com/alecthomas/gozmq"
)

func startWorker() {
    context, _ := zmq.NewContext()
    defer context.Close()

    worker, _ := context.NewSocket(zmq.REP)
    //err := worker.Connect("ipc:///backend")  // Tried it, but nothing
    //err := worker.Connect("inproc:///backend")  // Tried it, but nothing
    err := worker.Connect("tcp://127.0.0.1:5560") // this works
    if err != nil {
        fmt.Println(err)
    }

    for {
        data, err := worker.Recv(0)
        fmt.Println(string(data))
        worker.Send([]byte("I got your data"), 0)
    }
}

func main() {
    context, _ := zmq.NewContext()
    defer context.Close()

    // Socket facing clients
    frontend, _ := context.NewSocket(zmq.ROUTER)
    defer frontend.Close()
    frontend.Bind("tcp://*:5559")

    // Socket facing services
    backend, _ := context.NewSocket(zmq.DEALER)
    defer backend.Close()
    //backend.Bind("ipc:///backend")  // Tried it, but nothing
    //backend.Bind("inproc:///backend")  // Tried it, but nothing
    backend.Bind("tcp://*:5560") // this works

    for i := 0; i < 4; i++ {
        go startWorker() // Start workers in a separate goroutine
    }

    // Start built-in device
    zmq.Device(zmq.QUEUE, frontend, backend)

    // We never get here…
}

Answer 1

Для того, чтобы использовать inproc:// транспорт, все сокеты должны совместно использовать один и тот же контекст (который является потокобезопасным).

Также, если вы используете тот же контекст, вам не нужны какие-либо внутренние потоки ввода / вывода для ZMQ

Вы не упоминаете, под какой ОС вы работаете, но ipc:// транспорт доступен только под большинством *nix. Под окнами вы можете использовать только следующие транспорты: tcp://, inproc://, pgm://. Проверьте документацию zmq_connect для получения дополнительной информации.