Conic

WebSocket接続を使用したリアルタイムピアツーピア通信を促進するGo言語ベースのWebRTCシグナリングサーバーです。

機能

WebRTC接続用のWebSocketベースシグナリングサーバー
クライアント登録とメッセージルーティング
SDP（Session Description Protocol）交換のサポート
NAT越えのためのICE候補交換
データチャネルによるP2P通信サポート
自動WebRTCハンドシェイク処理（Offer/Answer）
リアルタイムチャット機能
Goチャンネルを使用した並行メッセージ処理
クリーンなインターフェースベースのアーキテクチャ

必要要件

Go 1.24.5 以降
依存関係ダウンロード用のインターネット接続

インストール

# リポジトリをクローン
git clone https://github.com/HMasataka/conic.git
cd conic

# 依存関係をインストール
go mod tidy

使用方法

サンプル作成

task generate-audio

データチャネルP2P通信デモ

完全なWebRTCピアツーピア通信を体験できます：

# インタラクティブなP2Pクライアントを起動
task datachannel

# オファー側として起動
task datachannel -role=offer

# アンサー側として起動
task datachannel -role=answer

デモの使い方

サーバー起動: まずシグナリングサーバーを起動
```
task signal
```

2つのクライアントを起動: 別々のターミナルで

# ターミナル1: オファー側
task datachannel -role=offer

# ターミナル2: アンサー側
task datachannel -role=answer

P2P接続の確立: オファー側でターゲットのピアIDを入力すると
自動的にWebRTCハンドシェイクが開始されます
リアルタイム通信: 接続が確立されるとデータチャネル経由での
リアルタイム通信が可能になります

利用可能なコマンド

offer <peer_id> - 指定したピアにWebRTCオファーを作成・送信
channel <label> - 新しいデータチャネルを作成
send <label> <message> - データチャネル経由でメッセージ送信
list - アクティブなデータチャネルを一覧表示
quit - 終了

オーディオ・ビデオストリーミングデモ

オーディオおよびビデオストリーミングのデモも利用可能です：

# オーディオデモ（Opusコーデック）
task audio-offer    # オファー側
task audio-answer   # アンサー側

# ビデオデモ（VP8コーデック）
task video-offer    # オファー側
task video-answer   # アンサー側

クイックスタート

P2P通信を素早く体験するには：

# ターミナル1: シグナリングサーバー起動
task signal

# ターミナル2: オファー側クライアント起動
task datachannel -role=offer

# ターミナル3: アンサー側クライアント起動
task datachannel -role=answer

オファー側でアンサー側のピアIDを入力
WebRTC接続が自動確立
データチャネル経由でリアルタイム通信開始！

API

WebSocketエンドポイント

URL: ws://localhost:3000/ws
プロトコル: JSONメッセージを使用するWebSocket

メッセージタイプ

クライアント登録

{
  "type": "register"
}

クライアント登録解除

{
  "type": "unregister",
  "raw": "{\"ID\": \"client-id\"}"
}

SDPオファー/アンサー送信

{
  "type": "sdp",
  "raw": "{\"ID\": \"sender-id\", \"TargetID\": \"receiver-id\", \"SessionDescription\": {...}}"
}

ICE候補送信

{
  "type": "candidate",
  "raw": "{\"ID\": \"sender-id\", \"TargetID\": \"receiver-id\", \"Candidate\": \"candidate-string\"}"
}

データチャネルメッセージ送信

{
  "type": "data_channel",
  "raw": "{\"ID\": \"sender-id\", \"TargetID\": \"receiver-id\", \"Label\": \"channel-name\", \"Data\": \"base64-encoded-data\"}"
}

アーキテクチャ

コアコンポーネント

Domain Layer (`domain/`)

Hub Interface: メッセージルーティングの契約定義
Client Interface: クライアント接続の契約定義
Message Types: JSONマーシャリング対応のメッセージ型定義
統計情報: Hub統計追跡機能

Internal Packages (`internal/`)

WebRTC (internal/webrtc/)
- PeerConnection: WebRTCピア接続管理（統計、ICE候補キューイング、エラー処理）
- DataChannel: データチャネル管理（統計、イベントハンドラー、スレッドセーフ操作）
Transport (internal/transport/)
- Client: サーバーサイドクライアント表現
- WebSocket Connection: WebSocket接続管理・アップグレード処理
Protocol (internal/protocol/)
- Message Handlers: メッセージタイプ別ハンドラー（register, SDP, candidate, data_channel）
- Router: メッセージルーティング設定

Hub Implementation (`hub/`)

Central Routing: クライアント登録・登録解除管理
Message Broadcasting: 接続クライアント間のメッセージルーティング
Connection Tracking: 接続統計と管理
Concurrent Processing: Goチャンネルを使用した並行処理

Audio Package (`internal/audio/`)

WAV Format: WAVファイル形式の処理
Sample Generation: テスト用サンプルオーディオの生成

Logging (`logging/`)

構造化ログ: Go slogパッケージ使用
コンテキスト対応: コンテキスト認識ログ
設定可能: レベルとフォーマット（JSON/テキスト）設定可能

WebRTCシグナリングプロセス

sequenceDiagram
    participant C1 as Client 1
    participant S as Signaling Server
    participant H as Hub
    participant C2 as Client 2

    Note over C1, C2: 1. 接続とクライアント登録

    C1->>+S: WebSocket接続 (ws://localhost:3000/ws)
    S->>S: WebSocket升級
    S->>+H: Socket作成とサービス開始

    C1->>S: {"type": "register"}
    S->>S: RegisterHandler処理
    S->>H: RegisterRequest {ID, Client}
    H->>H: clients[id] = client
    S-->>C1: RegisterResponse {ID}
    Note over C1: クライアントIDを受信・保存

    C2->>+S: WebSocket接続
    C2->>S: {"type": "register"}
    S->>H: RegisterRequest {ID, Client}
    H->>H: clients[id] = client
    S-->>C2: RegisterResponse {ID}

    Note over C1, C2: 2. WebRTCハンドシェイク開始

    C1->>C1: InitHandshake(config)
    C1->>C1: CreateDataChannel("test")
    C1->>C1: peerConnection.CreateOffer()

    C1->>S: {"type": "sdp", "raw": SDPRequest}
    Note right of S: SDPRequest: {ID, TargetID, SessionDescription}
    S->>S: SDPHandler処理
    S->>H: MessageRequest {ID, TargetID, Message}
    H->>C2: SDP Offerメッセージ転送

    Note over C2: 3. Answer作成と応答

    C2->>C2: handleSDP() - Offer受信
    C2->>C2: handshake.SetRemoteDescription(offer)
    C2->>C2: peerConnection.CreateAnswer()
    C2->>C2: handshake.SetLocalDescription(answer)

    C2->>S: {"type": "sdp", "raw": SDPRequest}
    Note right of S: SDPRequest: {ID, TargetID, SessionDescription}
    S->>H: MessageRequest {ID, TargetID, Message}
    H->>C1: SDP Answerメッセージ転送

    Note over C1, C2: 4. ICE候補交換

    C1->>C1: OnICECandidate イベント
    C1->>S: {"type": "candidate", "raw": CandidateRequest}
    S->>S: CandidateHandler処理
    S->>H: MessageRequest {ID, TargetID, Message}
    H->>C2: ICE候補メッセージ転送
    C2->>C2: handshake.AddIceCandidate()

    C2->>C2: OnICECandidate イベント
    C2->>S: {"type": "candidate", "raw": CandidateRequest}
    S->>H: MessageRequest {ID, TargetID, Message}
    H->>C1: ICE候補メッセージ転送
    C1->>C1: handshake.AddIceCandidate()

    Note over C1, C2: 5. データチャネル通信

    Note over C1: データチャネル確立後
    C1->>C1: dataChannel.OnOpen()
    C2->>C2: OnDataChannel() イベント

    C1->>C1: dataChannel.Send(data)
    Note right of C1: P2P直接通信
    C1-->>C2: データ送信 (P2P)

    Note over C1, C2: または、シグナリング経由でのデータ送信
    C1->>S: {"type": "data_channel", "raw": DataChannelRequest}
    S->>H: MessageRequest
    H->>C2: データチャネルメッセージ転送

アーキテクチャ構成図

graph TB
    subgraph "Client Side"
        C1[Client 1]
        C2[Client 2]

        subgraph "Client Components"
            WS[WebSocket Connection]
            HS[Handshake Manager]
            DC[DataChannel Manager]
        end
    end

    subgraph "Server Side"
        subgraph "Signal Package"
            WSS[WebSocket Server]
            SOC[Socket Handler]
        end

        subgraph "Internal Packages"
            subgraph "Transport Layer"
                WS[WebSocket Connection]
                CLI[Client Manager]
            end

            subgraph "Protocol Layer"
                RTR[Message Router]
                RH[RegisterHandler]
                UH[UnregisterHandler]
                SH[SDPHandler]
                CH[CandidateHandler]
                DH[DataChannelHandler]
            end

            subgraph "WebRTC Layer"
                PC[PeerConnection]
                DC[DataChannel]
            end
        end

        subgraph "Hub Package"
            HUB[Hub]
            REG[Register Channel]
            UNREG[Unregister Channel]
            MSG[Message Channel]
            CLIENTS[Client Registry]
        end
    end

    subgraph "WebRTC Layer"
        PC1[PeerConnection 1]
        PC2[PeerConnection 2]
        ICE[ICE Candidates]
        SDP[SDP Exchange]
    end

    C1 -.->|WebSocket| WSS
    C2 -.->|WebSocket| WSS

    WSS --> SOC
    SOC --> WS
    SOC --> CLI

    WS --> RTR
    CLI --> RTR

    RTR --> RH
    RTR --> UH
    RTR --> SH
    RTR --> CH
    RTR --> DH

    PC --> DC

    RH --> REG
    UH --> UNREG
    SH --> MSG
    CH --> MSG
    DH --> MSG

    REG --> HUB
    UNREG --> HUB
    MSG --> HUB

    HUB --> CLIENTS

    C1 --> PC1
    C2 --> PC2
    PC1 -.->|P2P Data| PC2

    PC --> ICE
    PC --> SDP

    PC1 --> ICE
    PC2 --> ICE
    PC1 --> SDP
    PC2 --> SDP

開発

利用可能なコマンド

# シグナリングサーバーを起動
task signal

# データチャネルデモを起動
task datachannel

# オーディオデモを起動
task audio-offer      # オファー側
task audio-answer     # アンサー側

# ビデオデモを起動
task video-offer      # オファー側
task video-answer     # アンサー側

# WAVサンプルを生成
task generate-audio

# プロジェクトをビルド
task build

# テストを実行
task test

# コードをフォーマット
task fmt

# コードの問題をチェック
task vet

# 依存関係を整理
task tidy

# ビルド成果物をクリーンアップ
task clean

# 利用可能なすべてのタスクを表示
task --list

# 開発ツールをインストール
task install-tools

# ホットリロード付きでサーバーを起動（airが必要）
task dev-server

プロジェクト構造

/
├── cmd/                          # コマンドラインアプリケーション
│   ├── signal/main.go           # シグナリングサーバー
│   ├── datachannel/main.go      # データチャネルP2Pデモ
│   ├── audio/main.go            # オーディオストリーミングデモ
│   ├── video/main.go            # ビデオストリーミングデモ
│   └── generate-audio/main.go   # WAVサンプル生成ユーティリティ
├── internal/                     # 内部パッケージ（外部から非公開）
│   ├── protocol/                # メッセージルーティング・HTTP処理
│   │   ├── router.go            # HTTPルーター・WebSocket升級
│   │   └── handler.go           # メッセージハンドラー
│   ├── transport/               # WebSocket通信層
│   │   ├── websocket.go         # WebSocketサーバー
│   │   └── client.go            # クライアント表現・メッセージルーティング
│   ├── webrtc/                  # WebRTCラッパーコンポーネント
│   │   ├── peer.go              # PeerConnection ラッパー
│   │   ├── datachannel.go       # DataChannel ラッパー
│   │   ├── audiotrack.go        # AudioTrack ラッパー
│   │   ├── videotrack.go        # VideoTrack ラッパー
│   │   ├── candidate.go         # ICE候補処理
│   │   └── errors.go            # WebRTCエラー定義
│   └── audio/                   # オーディオユーティリティ
│       └── wav.go               # WAVフォーマット処理
├── domain/                       # コアインターフェース・ドメインモデル
│   ├── client.go                # クライアントインターフェース
│   ├── data.go                  # メッセージ型定義
│   └── hub.go                   # ハブインターフェース
├── hub/                         # ハブ実装
│   └── hub.go                   # 中央メッセージルーター
├── registry/                    # WebRTCレジストレーション処理
│   └── handler.go               # Offer/Answer レジストレーション
├── logging/                     # ログユーティリティ
│   ├── logger.go                # 構造化ログ実装
│   └── context.go               # ログコンテキスト
├── context.go                   # グローバルコンテキストユーティリティ
├── go.mod                       # Goモジュール定義
├── Taskfile.yml                 # タスクランナー設定
└── docs/                        # ドキュメント
    ├── webrtc-terminology.md    # WebRTC用語解説
    └── ice-explanation.md       # ICEプロトコル解説

Name		Name	Last commit message	Last commit date
Latest commit History 86 Commits
cmd		cmd
domain		domain
hub		hub
internal		internal
logging		logging
registry		registry
signal		signal
.dockerignore		.dockerignore
CLAUDE.md		CLAUDE.md
Dockerfile		Dockerfile
README.md		README.md
Taskfile.yml		Taskfile.yml
compose.yml		compose.yml
context.go		context.go
go.mod		go.mod
go.sum		go.sum

HMasataka/conic

Folders and files

Latest commit

History

Repository files navigation

Conic

機能

必要要件

インストール

使用方法

サンプル作成

データチャネルP2P通信デモ

デモの使い方

利用可能なコマンド

オーディオ・ビデオストリーミングデモ

クイックスタート

API

WebSocketエンドポイント

メッセージタイプ

クライアント登録

クライアント登録解除

SDPオファー/アンサー送信

ICE候補送信

データチャネルメッセージ送信

アーキテクチャ

コアコンポーネント

Domain Layer (domain/)

Internal Packages (internal/)

Hub Implementation (hub/)

Audio Package (internal/audio/)

Logging (logging/)

WebRTCシグナリングプロセス

アーキテクチャ構成図

開発

利用可能なコマンド

プロジェクト構造

参考文献

Pion WebRTCを使用したP2Pシグナリングサーバープロジェクト

ファイル転送系

ネットワーク・トンネリング系

公式リソース

About

Resources

Uh oh!

Stars

Watchers

Forks

Releases

Packages 0

Uh oh!

Languages

Domain Layer (`domain/`)

Internal Packages (`internal/`)

Hub Implementation (`hub/`)

Audio Package (`internal/audio/`)

Logging (`logging/`)

Packages