UDP API¶

Oasis는 UDP(User Datagram Protocol) 서버와 클라이언트를 지원합니다.

보안 연결로 DTLS 버전1.2를 지원합니다.

헤더 파일¶

OasisNet.h

UdpEventDelegate 인터페이스¶

class UdpEventDelegate : public std::enable_shared_from_this<UdpEventDelegate>
{
public:
    UdpEventDelegate();
    virtual ~UdpEventDelegate();

public: 
};

현재는 정의되어 있는 이벤트 콜백 함수가 없습니다.

함수¶

아래는 UDP 연결 객체 생성에 필요한 key-value map입니다.

예제¶

UDP 서버¶

아래는 DTLS UDP 통신을 하는 서버 예입니다.

#include "OasisAPI.h"
#include "OasisLog.h"
#include "OasisNet.h"


#include <thread>
#include <mutex>
#include <memory>
#include <condition_variable>

#define DLOG_THIS   0x00080000

#undef DLOG_FLAGS
#define  DLOG_FLAGS (DLOG_FLAGS_DEFAULT|DLOG_THIS/**/)

#undef DLOG_TAG
#define DLOG_TAG "DTLSS"

#define USE_RSA 1
#define USE_ECDSA 0
#define USE_DSS 0

#define DTLS_CLIENT_VERIFY 0

using namespace oasis;

static bool continuing = true;

class MyUdpEventDelegate : public UdpEventDelegate
{
public:
  MyUdpEventDelegate() {}
  virtual ~MyUdpEventDelegate() {}


};


void cancel_handler(int signum)
{
  continuing = false;
}


int main(int argc, char* argv[])
{
  int32_t c, err;
  uint16_t port;
  std::thread t3;
  key_value_map_t parameters, fields;


  if(argc < 2) {
    printf("USAGE: %s <port number>\n", argv[0]);
    return 255;
  }

  port = (uint16_t)atoi(argv[1]);
  if(port == 0) {
    printf("USAGE: %s <port number>\n", argv[0]);
    return 255;
  }

  signal(SIGINT, cancel_handler);

  parameters["offs-disable"] = "1";
  if(oasis::initialize(parameters) < 0) {
    DLOG(DLOG_ERROR, "Oasis init failed\n");
    return -1;
  }

  parameters.clear();

#if DTLS_CLIENT_VERIFY
  //when restrict the accessible clients, each of which root ca should be the same as the server's.
  parameters["tls-client-verify"] = "1"; 
  //\x0a-seperated strings (if needs. by default server's CN used)
  parameters["tls-certificate-request-authority-names"] = "MediaStek-Root-CA\x0aMediaStek Inc.";
#endif

  parameters["ca-certs-file-path"] = "/data/certs/RootCA.pem";

#if USE_RSA
    parameters["cert-file-path"] = "/data/certs/fullchain.pem";
    parameters["pkey-file-path"] = "/data/certs/privkey.pem";
#elif USE_ECDSA
    //ECDSA
    parameters["cert-file-path"] = "/data/certs/ec_fullchain.pem";
    parameters["pkey-file-path"] = "/data/certs/ec_pkey.pem";
#elif USE_DSS
    parameters["cert-file-path"] = "/data/certs/dsa_fullchain.pem";
    parameters["pkey-file-path"] = "/data/certs/dsa_pkey.pem";
#else
    #error "No certficates!"
#endif

  std::shared_ptr<MyUdpEventDelegate> delegate = std::make_shared<MyUdpEventDelegate>();

  UdpConnectionRef conn;

  conn = udpCreate(nullptr, port, true, parameters);
  ASSERT(conn != nullptr);

  t3 = std::thread([&]() {

    do {

      DLOG(DLOG_THIS, "accepting...\n");
      int32_t c = udpAccept(conn, nullptr, 0, 0);

      DLOG(DLOG_THIS, "accepted socket %d\n", c);

      if(c >= 0) {

        uint8_t buffer[65536];
        ssize_t length = udpReceive(conn, c, buffer, sizeof(buffer), 100000);
        if(length > 0) {
          DUMP("RX", buffer, length);
        }

        udpClose(conn, c);
      }

    } while(continuing && conn);

  });

  do {
    usleep(100000);
  } while (continuing);

  udpDestroy(conn);

  if (t3.joinable()) {
    t3.join();
  }

  oasis::finalize();

  return 0;
}

UDP 클라이언트¶

아래는 DTLS UDP 서버에 접속 후 1초 간격으로 메세지를 전송하는 클라이언트 예입니다.

#include "OasisAPI.h"
#include "OasisLog.h"
#include "OasisNet.h"

#include <thread>
#include <mutex>
#include <memory>
#include <condition_variable>

#define DLOG_THIS   0x00080000

#undef DLOG_FLAGS
#define  DLOG_FLAGS (DLOG_FLAGS_DEFAULT|DLOG_THIS/**/)

#undef DLOG_TAG
#define DLOG_TAG "DTLSC"

using namespace oasis;

static bool continuing = true;

void cancel_handler(int signum)
{
  continuing = false;
}


int main(int argc, char* argv[])
{
  int32_t err;

  int32_t status_code;
  std::string reason_string;
  std::string content_type; 
  std::vector<char> res_content;
  size_t content_length;

  int32_t wait_count = 0;

  key_value_map_t parameters, fields;


  if(argc < 3) {
    printf("USAGE: %s <target address> <port>\n", argv[0]);
    return 255;
  }

  signal(SIGINT, cancel_handler);

  const char *remote_ip = argv[1];
  uint16_t remote_port = (uint16_t)atoi(argv[2]);
  if(remote_port == 0) {
    printf("USAGE: %s <target address> <port>\n", argv[0]);
    return 255;
  }

  parameters["offs-disable"] = "1";
  if(oasis::initialize(parameters) < 0) {
    DLOG(DLOG_ERROR, "Oasis init failed\n");
    return -1;
  }

  parameters.clear();

  parameters["ca-certs-file-path"] = "/data/certs/cacerts.pem\x0a/data/certs/RootCA.pem";
  parameters["cert-file-path"] = "/data/certs/client_fullchain.pem";
  parameters["pkey-file-path"] = "/data/certs/client_privkey.pem";

  UdpConnectionRef conn;
  char buffer[512];
  ssize_t len;
  int ch;

  conn = udpCreate(nullptr, 0, true, parameters);
  if(conn) {

    int32_t c = udpConnect(conn, remote_ip, remote_port, 10000);

    if(c >= 0) {

      DLOG(DLOG_THIS, "connected %d\n", c);
      DLOG(DLOG_THIS, "press Ctrl+C to disconnect and quit.\n");

      do {

        fprintf(stdout, "> ");
        fflush(stdout);

        len = 128;
        for(int32_t i=0; i<len; i++) {
          buffer[i] = '0' + (i%10);
        }
        buffer[len] = 0;
        udpSend(conn, c, buffer, len);
        usleep(1000000);

      } while (continuing);

      udpClose(conn, c);
    }

    udpDestroy(conn);
  }

  conn = nullptr;

done:

  oasis::finalize();

  return 0;
}