1
2
3
4
5
6
7

com.<your-org>.stream.gb28181
├── SipLayer              # SIP 服务端（监听 5060 端口）
├── config                # 配置（信令端口、IP、上级平台）
├── media                 # 媒体流转发
├── session               # 客户端会话管理
├── event                 # 事件订阅与通知
└── controller            # REST API（前端调用）

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

<dependencies>
    <!-- SIP 协议栈 -->
    <dependency>
        <groupId>javax.sip</groupId>
        <artifactId>jain-sip-ri</artifactId>
        <version>1.3.0-91</version>
    </dependency>

    <!-- Spring Boot Web -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!-- ZLMediaKit Java SDK -->
    <dependency>
        <groupId>com.aizuda</groupId>
        <artifactId>zlmediakit-java-sdk</artifactId>
    </dependency>
</dependencies>

1
2
3
4
5
6

public class SipProviderImpl implements
        SipProvider,           // 公共 SIP 接口
        SipProviderExt,        // 扩展接口
        SIPTransactionEventListener,  // 事务事件
        SIPDialogEventListener {     // 对话事件
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

public interface SipListener extends EventListener {
    // 1. SIP 请求消息到达时  REGISTER/INVITE/BYE/MESSAGE
    void processRequest(RequestEvent event);

    // 2. SIP 响应消息到达时（200 OK / 401 / 403 等）
    void processResponse(ResponseEvent event);

    // 3. SIP 事务超时（INVITE 超时、OPTIONS 心跳超时等）
    void processTimeout(TimeoutEvent event);

    // 4. 网络 I/O 异常（连接断开、发送失败）
    void processIOException(IOExceptionEvent event);

    // 5. SIP 事务结束（ACK 收到后 INVITE 事务终结）
    void processTransactionTerminated(TransactionTerminatedEvent event);

    // 6. SIP 对话（Dialog）结束（双方会话完全终结）
    void processDialogTerminated(DialogTerminatedEvent event);
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

@Slf4j
@Component
@Order(value = 10)
public class SipLayer implements CommandLineRunner {
    @Autowired
    private SipConfig sipConfig;

    @Autowired
    private ISIPProcessorObserver sipProcessorObserver;

    @Autowired
    private UserSetting userSetting;

    // TCP 与 UDP 的 SIP Provider 映射
    private final Map<String, SipProviderImpl> tcpSipProviderMap = new ConcurrentHashMap<>();
    private final Map<String, SipProviderImpl> udpSipProviderMap = new ConcurrentHashMap<>();

    // 已监听过的 IP（防止重复 bind）
    private final List<String> monitorIps = new ArrayList<>();

    @Override
    public void run(String... args) {
        // 应用启动时初始化 SIP 监听
        initSipServer();
    }

    public SipProviderImpl getUdpSipProvider(String ip) { /* ... */ }
    public SipProviderImpl getUdpSipProvider() { /* ... */ }
    public SipProviderImpl getTcpSipProvider(String ip) { /* ... */ }
    public SipProviderImpl getTcpSipProvider() { /* ... */ }
    public String getLocalIp(String deviceLocalIp) { /* ... */ }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

  Device    WVP Controller    sipCommander    设备    CatalogResponseMessageHandler    DeviceChannelMapper    DB
    │           │                 │            │                  │                      │              │
    │─注册成功─▶│                 │            │                  │                      │              │
    │           │─sync(device)───▶│            │                  │                      │              │
    │           │                 │─CatalogQuery─▶│                │                      │              │
    │           │                 │◀──Catalog XML─│                │                      │              │
    │           │                 │            │──handle()───────▶│                      │              │
    │           │                 │            │                  │──batchAdd───────────▶│              │
    │           │                 │            │                  │──batchUpdate────────▶│              │
    │           │                 │            │                  │──batchDel───────────▶│              │

1
2
3
4
5
6

设备 → REGISTER → SipLayer（UDP 5060）
                 → SipListener.processRequest()
                 → ISIPRequestObserver（注册处理器）
                 → 校验设备 ID + 密码
                 → 更新设备状态为"在线"
                 → 200 OK

1
2
3
4
5

设备 → MESSAGE（Keepalive） → SipLayer
                            → SipListener.processRequest()
                            → 解析 XML 设备状态
                            → 更新设备最后心跳时间
                            → 200 OK

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

WVP Controller 触发"同步通道"
  → DeviceService.sync()
  → sipCommander.catalogQuery(device, deviceChannel)
  → SIP MESSAGE（带 Catalog 查询 XML）
  → 设备 → 200 OK
  → 设备 → SIP MESSAGE（异步返回 Catalog 列表）
  → SipLayer → CatalogResponseMessageHandler.handle()
  → 解析 XML 中的通道列表
  → DeviceChannelMapper.batchAdd(新增通道)
  → DeviceChannelMapper.batchUpdate(更新通道)
  → DeviceChannelMapper.batchDel(删除通道)
  → 写入 DB

1
2
3
4
5
6
7

public interface ISIPRequestProcessor {
    // 处理方法名
    String getMethod();

    // 处理逻辑
    void process(RequestEvent event);
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17

public class SIPRequestProcessorParent implements SipListener {
    @Autowired
    private List<ISIPRequestProcessor> processors;  // Spring 自动注入

    @Override
    public void processRequest(RequestEvent event) {
        Request request = event.getRequest();
        String method = request.getMethod();

        for (ISIPRequestProcessor processor : processors) {
            if (method.equals(processor.getMethod())) {
                processor.process(event);
                break;
            }
        }
    }
}

1
2
3

GB28181 设备 → RTP/PS 流 → WVP 接收 → ZLMediaKit 拉流
                                       → 转 RTMP/HLS/WebRTC
                                       → 推到客户端

1
2
3
4
5
6
7
8

// WVP 通过 HTTP API 调用 ZLMediaKit
POST http://zlmediakit:9000/index/api/openRtpServer
Body:
{
  "port": 10000,
  "enable_tcp": true,
  "stream_id": "channel_001"
}

1
2
3
4

# 错误：Address already in use
# 原因：5060 端口被系统 SIP 服务占用
lsof -i :5060
# 解决：修改 WVP 配置改用其他端口

1
2
3
4
5
6
7

GB28181 摄像头 → WVP（信令）→ ZLMediaKit（流媒体）
                                 ↓
                          AI 分析服务（Python + YOLOv8）
                                 ↓
                          告警 → Kafka → 业务系统
                                 ↓
                          录像 → MinIO / 阿里 OSS

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

// 浏览器端 WebRTC 拉流（2024+ 主流）
const pc = new RTCPeerConnection();
pc.addTransceiver('video', { direction: 'sendrecv' });
pc.addTransceiver('audio', { direction: 'sendrecv' });

const offer = await pc.createOffer();
await pc.setLocalDescription(offer);

// 拉 ZLMediaKit 的 WebRTC 流
const resp = await fetch('http://zlmediakit:9000/index/api/webrtc?app=live&stream=cam001&type=play');
const answer = await resp.json();
await pc.setRemoteDescription(answer);

pc.ontrack = (event) => {
  document.getElementById('video').srcObject = event.streams[0];
};