itssofluffy / nanomessage Goto Github PK

View Code? Open in Web Editor NEW

8.0 2.0 2.0 512 KB

nanomsg library as swift classes

License: MIT License

Makefile 0.15% Swift 99.67% Shell 0.16% Dockerfile 0.03%

nanomsg swift

nanomessage's Introduction

NanoMessage

NanoMessage is a Swift-3/4 class wrapper of nanomsg

Socket Protocols

Transport Mechanisms

TCP/IP
In-Process Communication
Inter-Process Communication
Web Socket

Features

Send/Receive (Synchronous/Asynchronous) Blocking/Non-Blocking And Timeout
Same message payload object for Send/Receive with message context
Socket Polling (Single or Multiple)
Device/Socket Binding (Synchronous/Asynchronous)
Socket Loopback (Synchronous/Asynchronous)

Usage

If Swift Package Manager is used, add this package as a dependency in Package.swift,

import PackageDescription

let package = Package (
    name:  "<your-app-name>",
    dependencies: [
        .Package(url: "https://github.com/itssofluffy/NanoMessage.git", majorVersion: 0)
    ]
)

Examples

Push

import Foundation
import NanoMessage

do {
    guard let url = URL(string: "tcp://localhost:5555") else {
        fatalError("url is not valid")
    }

    let node = try PushSocket()

    let _: Int = try node.createEndPoint(url: url, type: .Connect)

    try node.sendMessage(Message(value: "This is earth calling...earth calling..."),
                         timeout: TimeInterval(seconds: 10))
} catch let error as NanoMessageError {
    print(error)
} catch {
    print("an unexpected error '\(error)' has occured in the library libNanoMessage.")
}

Pull

import Foundation
import NanoMessage

do {
    guard let url = URL(string: "tcp://*:5555") else {
        fatalError("url is not valid")
    }

    let node = try PullSocket()

    let endPoint: EndPoint = try node.createEndPoint(url: url, type: .Bind, name: "my local end-point")

    let received = try node.receiveMessage(timeout: TimeInterval(seconds: 10))

    print("bytes  : \(received.bytes)")            // 40
    print("message: \(received.message.string)")   // This is earth calling...earth calling...

    if (try node.removeEndPoint(endPoint)) {
        print("end-point removed")
    }
} catch let error as NanoMessageError {
    print(error)
} catch {
    print("an unexpected error '\(error)' has occured in the library libNanoMessage.")
}

Request

import Foundation
import NanoMessage

do {
    guard let url = URL(string: "tcp://localhost:5555") else {
        fatalError("url is not valid")
    }

    let node = try RequestSocket()

    let endPoint: EndPoint = try node.createEndPoint(url: url, type: .Connect, name: "request end-point")

    usleep(TimeInterval(milliseconds: 200))

    let timeout = TimeInterval(seconds: 10)
    let message = Message(value: "ping")

    let received = try node.sendMessage(message, sendTimeout: timeout, receiveTimeout: timeout) { sent in
        print("sent \(sent)")
    }

    print("and recieved \(received)")
} catch let error as NanoMessageError {
    print(error)
} catch {
    print("an unexpected error '\(error)' has occured in the library libNanoMessage.")
}

import Foundation
import NanoMessage

do {
    guard let url = URL(string: "tcp://*:5555") else {
        fatalError("url is not valid")
    }

    let node = try ReplySocket()

    let endPoint: EndPoint = try node.createEndPoint(url: url, type: .Bind, name: "reply end-point")

    usleep(TimeInterval(milliseconds: 200))

    let timeout = TimeInterval(seconds: 10)

    let sent = try node.receiveMessage(receiveTimeout: timeout, sendTimeout: timeout) { received in
        print("received \(received)")

        var message = ""

        if (received.message.string == "ping") {
            message = "pong"
        } else {
            message = "personally i prefer wiff-wafe"
        }

        return Message(value: message)
    }

    print("and sent \(sent)")
} catch let error as NanoMessageError {
    print(error)
} catch {
    print("an unexpected error '\(error)' has occured in the library libNanoMessage.")
}