first commit

.gitignore

@@ -0,0 +1,37 @@
+### Go template
+# If you prefer the allow list template instead of the deny list, see community template:
+# https://github.com/github/gitignore/blob/main/community/Golang/Go.AllowList.gitignore
+#
+# Binaries for programs and plugins
+*.dll
+*.so
+*.dylib
+camostream
+# Test binary, built with `go test -c`
+*.test
+
+# Output of the go coverage tool, specifically when used with LiteIDE
+*.out
+
+# Dependency directories (remove the comment below to include it)
+# vendor/
+
+# Go workspace file
+go.work
+go.work.sum
+
+# env file
+.env
+
+### Go.AllowList template
+# Allowlisting gitignore template for GO projects prevents us
+# from adding various unwanted local files, such as generated
+# files, developer configurations or IDE-specific files etc.
+#
+# Recommended: Go.AllowList.gitignore
+
+# Ignore everything
+# But not these files...
+!/.gitignore
+
+

.idea/.gitignore

@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

.idea/camostream.iml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true" />
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/camostream.iml" filepath="$PROJECT_DIR$/.idea/camostream.iml" />
+    </modules>
+  </component>
+</project>

.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>

README.md

@@ -0,0 +1,98 @@
+### CamoStreamPro
+
+>我也不知道有什么用
+
+#### build
+
+```bash
+go build -o camostream main.go
+```
+
+#### tcp 
+
+```bash
+
+./camostream -role=client -mode=tcp -listen=:37001 -server=127.0.0.1:39001 \
+  -bitrate-mbps=20 -decoy-rps=10 \
+  -pcap=tcp_client.pcap -pcap-max-mb=50 -metrics=:9101 -log=info
+  
+  
+./camostream -role=server -mode=tcp -listen=:39001 -forward=127.0.0.1:4141 \
+  -bitrate-mbps=20 -decoy-rps=10 \
+  -pcap=tcp_server.pcap -pcap-max-mb=50 -metrics=:9100 -log=info
+
+```
+
+
+
+
+
+
+
+
+#### udp
+
+```bash
+./camostream -role=server -mode=udp -listen=:39001 -forward=127.0.0.1:18081 \
+  -wire=rtpish -fps=60 -bitrate-mbps=20 \
+  -decoy-rps=12 \
+  -rtcp-sr-rps=2 -rtcp-rr-rps=3 -rtpkeep-rps=4 -stun-rps=1 \
+  -pcap=udp_server.pcap -pcap-max-mb=100 -metrics=:9100 -log=info
+  
+  
+./camostream -role=client -mode=udp -listen=:37001 -server=127.0.0.1:39001 \
+  -wire=rtpish -fps=60 -bitrate-mbps=20 \
+  -decoy-rps=12 \
+  -rtcp-sr-rps=2 -rtcp-rr-rps=3 -rtpkeep-rps=4 -stun-rps=1 \
+  -pcap=udp_client.pcap -pcap-max-mb=100 -metrics=:9101 -log=info
+  
+```
+
+
+
+
+#### feat
+
+*	✅ UDP/TCP 双协议、Client/Server 双角色
+*	✅ UDP：RTP-ish（12B RTP 头）+ shim 载荷、60/120fps、GOP 峰谷、抖动
+*	✅ 码率整形（令牌桶）
+*	✅ 诱饵插播（shim‑decoy）+ AES‑GCM 可选
+*	✅ 额外伪报文（UDP 无 shim）：RTCP SR、RTCP RR、纯 RTP keepalive、STUN Binding
+*	✅ 自测模式（UDP Echo + Client/Server + 负载）
+*	✅ PCAP（UDP RAW）与指标（/debug/vars）
+
+
+#### 增强
+
+*	UDP 方向新增无 shim 的额外伪报文（中间盒可见，但业务端不感知）：
+*	RTCP SR（PT=200）：包含 sender SSRC、NTP 时间戳、RTP 时间戳、包/字节计数。
+*	RTCP RR（PT=201）：简单接收者报告，无 report block。
+*	纯 RTP keepalive：PT=13（CN 习惯），小 payload/可零 payload。
+*	STUN Binding Request：标准 20B 报文，含 Magic Cookie 和 Transaction ID。
+这些报文不带 shim，因此服务端在解析 RTP-ish+shim 失败时直接 continue 丢弃；同样客户端也会丢弃，从而只起到“流量伪装/背景噪声”作用。
+*	仍保持诱饵为“插播”（不替代真实帧）：
+*	TCP：真实帧 → （可选）插播 shim‑decoy。
+*	UDP：真实帧（RTP-ish+shim 或 shim）→ （可选）插播 shim‑decoy → （可选）插播 RTCP/RTP/STUN 等额外无壳伪报文。
+*	新增 CLI 控制这类伪报文注入概率（UDP only）：
+*	-rtcp-sr-pct：插播 RTCP SR 的概率（默认 4）
+*	-rtcp-rr-pct：插播 RTCP RR 的概率（默认 6）
+*	-rtpkeep-pct：插播纯 RTP keepalive 的概率（默认 5）
+*	-stun-pct：插播 STUN Binding 的概率（默认 3）
+
+
+>备注：-wire=rtpish 仅对 UDP 生效；TCP 会打印一个 WARN 并忽略
+
+
+
+
+#### 指标
+
+*	http://127.0.0.1:9100/debug/vars（server）
+*	http://127.0.0.1:9101/debug/vars（client）
+*	关注：bytes_*、frames_*、decoy_dropped、shim_decoy_sent、rtcp_sr_sent、rtcp_rr_sent、rtp_keepalive_sent、stun_sent
+
+
+#### Warn
+
+仅用于授权的内部安全测试。涉及伪装/混淆的功能，请严格遵循公司及法律合规要求。
+TCP 的 PCAP 是伪造的网络层帧，用于 debug 观察我们应用层写入/读到的 shim 帧，不代表内核真实的 TCP 会话（没有三次握手、窗口/ACK 真实演进），但校验和正确，可在 Wireshark 中查看和过滤。

client.sh

@@ -0,0 +1,5 @@
+#!/bin/bash
+
+./camostream -role=client -mode=tcp -listen=:37001 -server=127.0.0.1:39001 \
+  -bitrate-mbps=20 -decoy-rps=10 \
+  -pcap=tcp_client.pcap -pcap-max-mb=50 -metrics=:9101 -log=info

client_udp.sh

@@ -0,0 +1,7 @@
+#!/bin/bash
+
+./camostream -role=client -mode=udp -listen=:37001 -server=127.0.0.1:39001 \
+  -wire=rtpish -fps=60 -bitrate-mbps=20 \
+  -decoy-rps=12 \
+  -rtcp-sr-rps=2 -rtcp-rr-rps=3 -rtpkeep-rps=4 -stun-rps=1 \
+  -pcap=udp_client.pcap -pcap-max-mb=100 -metrics=:9101 -log=info

go.mod

@@ -0,0 +1,3 @@
+module camostream
+
+go 1.24.3

kill.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+
+ ps -ef |grep camostream | awk '{print $2}' | xargs kill -9

server.sh

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+./camostream -role=server -mode=tcp -listen=:39001 -forward=127.0.0.1:4141 \
+  -bitrate-mbps=20 -decoy-rps=10 \
+  -pcap=tcp_server.pcap -pcap-max-mb=50 -metrics=:9100 -log=info
+

server_udp.sh

@@ -0,0 +1,8 @@
+#!/bin/bash
+
+./camostream -role=server -mode=udp -listen=:39001 -forward=127.0.0.1:18081 \
+  -wire=rtpish -fps=60 -bitrate-mbps=20 \
+  -decoy-rps=12 \
+  -rtcp-sr-rps=2 -rtcp-rr-rps=3 -rtpkeep-rps=4 -stun-rps=1 \
+  -pcap=udp_server.pcap -pcap-max-mb=100 -metrics=:9100 -log=info
+

sim/README.md

@@ -0,0 +1,17 @@
+
+### udp_测试
+
+* client 使用脚本 [client_udp.sh](../client_udp.sh)
+* server 使用脚本 [server_udp.sh](../server_udp.sh)
+
+
+```shell
+
+echo -n "test" | nc -u 127.0.0.1 37001
+HTTP/1.1 200 OK
+Content-Type: text/html; charset=UTF-8
+Content-Length: 60
+
+<html><body><h1>Hello from UDP HTML Server!</h1></body></html>
+ 
+```

sim/udp_server.go

@@ -0,0 +1,44 @@
+package main
+
+import (
+	"fmt"
+	"net"
+)
+
+func main() {
+	addr := net.UDPAddr{
+		Port: 18081,
+		IP:   net.ParseIP("0.0.0.0"),
+	}
+
+	conn, err := net.ListenUDP("udp", &addr)
+	if err != nil {
+		panic(err)
+	}
+	defer conn.Close()
+
+	fmt.Println("UDP server listening on", addr.String())
+
+	buf := make([]byte, 2048)
+
+	for {
+		n, clientAddr, err := conn.ReadFromUDP(buf)
+		if err != nil {
+			fmt.Println("read error:", err)
+			continue
+		}
+
+		fmt.Printf("Received from %s: %s\n", clientAddr.String(), string(buf[:n]))
+
+		htmlResponse := `HTTP/1.1 200 OK
+Content-Type: text/html; charset=UTF-8
+Content-Length: 60
+
+<html><body><h1>Hello from UDP HTML Server!</h1></body></html>`
+
+		_, err = conn.WriteToUDP([]byte(htmlResponse), clientAddr)
+		if err != nil {
+			fmt.Println("write error:", err)
+		}
+	}
+}