From 6f1e7a63fa6afc261ba2247bf1d56f59dbb9f4c9 Mon Sep 17 00:00:00 2001
From: WXL <1785969728@qq.com>
Date: 星期四, 07 八月 2025 17:29:46 +0800
Subject: [PATCH] 测试完成
---
src/utils/sipService.js | 279 ++++++++++++++++++++++++++++++++-----------------------
1 files changed, 162 insertions(+), 117 deletions(-)
diff --git a/src/utils/sipService.js b/src/utils/sipService.js
index 4b12914..b93e184 100644
--- a/src/utils/sipService.js
+++ b/src/utils/sipService.js
@@ -4,10 +4,11 @@
constructor() {
this.ua = null;
this.currentSession = null;
- this.onStatusChange = null; // 鐘舵�佸彉鍖栧洖璋�
+ this.onStatusChange = null;
+ this.onCallStatusChange = null;
+ this.onIncomingCall = null;
}
- // 鍒濆鍖朣IP瀹㈡埛绔�
init(config) {
try {
this.updateStatus("connecting", "杩炴帴涓�...");
@@ -17,140 +18,161 @@
uri: config.sipUri,
password: config.password,
display_name: config.displayName,
- iceservers:[],
- // realm: config.realm,
+ iceServers: [{ urls: "stun:stun.l.google.com:19302" }],
register: true,
- session_expires: 180,
- sessionTimersExpires: 300, // 璁剧疆 Session-Expires=120锛堝繀椤� >= Min-SE锛�
- extraHeaders: [
- "Min-SE: 120", // 鍙�夛細鏄惧紡鍛婅瘔鏈嶅姟鍣ㄤ綘鏀寔鐨勬渶灏忓��
- ],
- register_expires: 300, // 娉ㄥ唽鏈夋晥鏈�(绉�)
- connection_recovery_min_interval: 2, // 鏈�灏忛噸杩為棿闅�
- connection_recovery_max_interval: 30, // 鏈�澶ч噸杩為棿闅�
+ session_expires: 900,
+ sessionTimersExpires: 600,
+ extraHeaders: ["Min-SE: 120"],
+ register_expires: 300,
+ connection_recovery_min_interval: 2,
+ connection_recovery_max_interval: 30,
+ pcConfig: {
+ iceTransportPolicy: "all",
+ rtcpMuxPolicy: "require",
+ bundlePolicy: "max-bundle"
+ }
});
this.ua.start();
- // 娉ㄥ唽浜嬩欢鐩戝惉
- this.ua.on("registered", () => {
- this.updateStatus("registered", "宸叉敞鍐�");
- });
+ // 浜嬩欢鐩戝惉
+ this.ua.on("registered", () => this.updateStatus("registered", "宸叉敞鍐�"));
+ this.ua.on("registrationFailed", (e) =>
+ this.updateStatus("failed", `娉ㄥ唽澶辫触: ${e.cause}`));
+ this.ua.on("disconnected", () =>
+ this.updateStatus("disconnected", "杩炴帴鏂紑"));
+ this.ua.on("connected", () =>
+ this.updateStatus("connecting", "閲嶆柊杩炴帴涓�..."));
+ this.ua.on("newRTCSession", (data) =>
+ this.handleIncomingCall(data.session));
- this.ua.on("registrationFailed", (e) => {
- this.updateStatus("failed", `娉ㄥ唽澶辫触: ${e.cause}`);
- });
-
- this.ua.on("disconnected", () => {
- this.updateStatus("disconnected", "杩炴帴鏂紑");
- });
-
- this.ua.on("connected", () => {
- this.updateStatus("connecting", "閲嶆柊杩炴帴涓�...");
- });
-
- // 鐩戝惉鏉ョ數
- this.ua.on("newRTCSession", (data) => {
- this.handleIncomingCall(data.session);
- });
} catch (error) {
this.updateStatus("failed", `鍒濆鍖栧け璐�: ${error.message}`);
console.error("SIP鍒濆鍖栧け璐�:", error);
- }
- }
- handleIncomingCall(session) {
- if (session.direction === "incoming") {
- console.log("鏉ョ數:", session.remote_identity.uri.toString());
- // 鍙互鍦ㄨ繖閲岃Е鍙� UI 閫氱煡
- if (this.onIncomingCall) {
- this.onIncomingCall(session);
- }
+ throw error;
}
}
- // 鏇存柊鐘舵�佸苟閫氱煡UI
- updateStatus(type, text) {
- console.log(`SIP鐘舵�佹洿鏂�: ${type} - ${text}`);
- if (this.onStatusChange) {
- this.onStatusChange({ type, text });
- }
- }
-
- // 涓�閿嫧鍙� - 澧炲姞娉ㄥ唽鐘舵�佹鏌�
makeCall(targetNumber) {
- if (!this.ua) {
- throw new Error("SIP瀹㈡埛绔湭鍒濆鍖�");
- }
+ return new Promise((resolve, reject) => {
+ try {
+ if (!this.ua) {
+ throw new Error("SIP瀹㈡埛绔湭鍒濆鍖�");
+ }
- if (!this.ua.isRegistered()) {
- throw new Error("SIP鏈敞鍐岋紝鏃犳硶鍛煎彨");
- }
+ if (!this.ua.isRegistered()) {
+ throw new Error("SIP鏈敞鍐岋紝鏃犳硶鍛煎彨");
+ }
- const options = {
- sessionTimers: true,
- sessionTimersExpires: 300,
- extraHeaders: [
- "Min-SE: 120",
- "Route: <sip:@192.168.100.6>",
- "Accept: application/sdp",
- "Supported: replaces, timer",
- "Allow: INVITE, ACK, BYE, CANCEL, OPTIONS",
- ],
- eventHandlers: {
- progress: (e) => console.log("鍛煎彨涓�..."),
- failed: (e) => console.error("鍛煎彨澶辫触:", e),
- ended: (e) => console.log("閫氳瘽缁撴潫"),
- confirmed: (e) => console.log("閫氳瘽宸叉帴閫�"),
- },
- mediaConstraints: {
- audio: true,
- video: false,
- },
- rtcOfferConstraints: {
- offerToReceiveAudio: 1,
- offerToReceiveVideo: 0,
- mandatory: {
- OfferToReceiveAudio: true,
- OfferToReceiveVideo: false,
- },
- },
- pcConfig: {
- iceServers: [{ urls: "stun:stun.l.google.com:19302" }],
- iceTransportPolicy: "all",
- bundlePolicy: "balanced",
- rtcpMuxPolicy: "require",
- codecs: {
- audio: [
- { name: "PCMU", clockRate: 8000, payloadType: 0 },
- { name: "PCMA", clockRate: 8000, payloadType: 8 },
+ const options = {
+ sessionTimers: false, // 鏆傛椂绂佺敤浠ュ噺灏戝吋瀹规�ч棶棰�
+ extraHeaders: [
+ "Min-SE: 120",
+ "Accept: application/sdp",
+ "Supported: outbound"
],
- video: [],
- },
- },
- };
+ mediaConstraints: { audio: true, video: false },
+ rtcOfferConstraints: {
+ offerToReceiveAudio: true,
+ offerToReceiveVideo: false
+ },
+ eventHandlers: {
+ progress: () => this.updateCallStatus("calling", "鍛煎彨涓�..."),
+ failed: (e) => {
+ this.handleCallFailure(e, reject);
+ },
+ ended: () => this.updateCallStatus("ended", "閫氳瘽缁撴潫"),
+ confirmed: () => {
+ this.updateCallStatus("connected", "閫氳瘽宸叉帴閫�");
+ resolve();
+ }
+ }
+ };
- this.currentSession = this.ua.call(
- `sip:${targetNumber}@192.168.100.6`,
- options
- );
- // 鍦ㄤ細璇濆垱寤哄悗淇敼 SDP
- this.currentSession.on("peerconnection", (pc) => {
- pc.createOffer = (offerOptions) => {
- return RTCPeerConnection.prototype.createOffer
- .call(pc, offerOptions)
- .then((offer) => {
- const modifiedSdp = offer.sdp
- .replace(/c=IN IP4 192\.168\.100\.10/g, "c=IN IP4 192.168.100.6")
- .replace(/m=audio \d+ RTP\/AVP.*/, "m=audio 7078 RTP/AVP 0 8");
- return new RTCSessionDescription({
- type: "offer",
- sdp: modifiedSdp,
- });
- });
+ this.currentSession = this.ua.call(
+ `sip:${targetNumber}@192.168.10.124`,
+ options
+ );
+
+ this.setupPeerConnection(this.currentSession);
+ this.setupAudio(this.currentSession);
+
+ } catch (error) {
+ this.updateCallStatus("failed", `鍛煎彨澶辫触1: ${error.message}`);
+ reject(error);
+ }
+ });
+ }
+
+ setupPeerConnection(session) {
+ session.on("peerconnection", (pc) => {
+ const originalCreateOffer = pc.createOffer.bind(pc);
+
+ pc.createOffer = async (offerOptions) => {
+ try {
+ const offer = await originalCreateOffer(offerOptions);
+ return this.normalizeSDP(offer);
+ } catch (error) {
+ console.error("鍒涘缓Offer澶辫触:", error);
+ throw error;
+ }
};
});
- this.setupAudio(this.currentSession);
}
+
+ normalizeSDP(offer) {
+ let sdp = offer.sdp;
+
+ // 1. 鏍囧噯鍖栬繛鎺ヨ
+ sdp = sdp.replace(/c=IN IP4.*\r\n/, "c=IN IP4 0.0.0.0\r\n");
+
+ // 2. 鏍囧噯鍖栭煶棰戝獟浣撹
+ sdp = sdp.replace(/m=audio \d+.*\r\n/,
+ "m=audio 9 UDP/TLS/RTP/SAVPF 0 8\r\n");
+
+ // 3. 纭繚鍖呭惈鍩烘湰缂栬В鐮佸櫒
+ if (!sdp.includes("PCMU/8000")) {
+ sdp += "a=rtpmap:0 PCMU/8000\r\n";
+ }
+ if (!sdp.includes("PCMA/8000")) {
+ sdp += "a=rtpmap:8 PCMA/8000\r\n";
+ }
+
+ // 4. 娣诲姞蹇呰灞炴��
+ sdp += "a=rtcp-mux\r\n";
+ sdp += "a=sendrecv\r\n";
+
+ console.log("鏍囧噯鍖栧悗鐨凷DP:", sdp);
+ return new RTCSessionDescription({
+ type: offer.type,
+ sdp: sdp
+ });
+ }
+
+ handleCallFailure(e, reject) {
+ console.error("鍛煎彨澶辫触璇︽儏:", {
+ cause: e.cause,
+ message: e.message,
+ response: e.response && e.response.status_code
+ });
+
+ let errorMessage = "鍛煎彨澶辫触";
+ switch(e.cause) {
+ case "Incompatible SDP":
+ errorMessage = "濯掍綋鍗忓晢澶辫触锛岃妫�鏌ョ紪瑙ｇ爜鍣ㄩ厤缃�";
+ break;
+ case "488":
+ case "606":
+ errorMessage = "瀵规柟璁惧涓嶆敮鎸佸綋鍓嶅獟浣撻厤缃�";
+ break;
+ default:
+ errorMessage = `鍛煎彨澶辫触: ${e.cause || e.message}`;
+ }
+
+ this.updateCallStatus("failed2", errorMessage);
+ reject(new Error(errorMessage));
+ }
+
setupAudio(session) {
session.connection.addEventListener("addstream", (e) => {
const audioElement = document.getElementById("remoteAudio");
@@ -159,14 +181,37 @@
}
});
}
- // 鎸傛柇褰撳墠閫氳瘽
+
endCall() {
if (this.currentSession) {
this.currentSession.terminate();
+ this.updateCallStatus("ended", "閫氳瘽宸茬粨鏉�");
this.currentSession = null;
}
}
+ updateStatus(type, text) {
+ console.log(`SIP鐘舵�佹洿鏂�: ${type} - ${text}`);
+ if (this.onStatusChange) {
+ this.onStatusChange({ type, text });
+ }
+ }
+
+ updateCallStatus(type, text) {
+ console.log(`閫氳瘽鐘舵�佹洿鏂�: ${type} - ${text}`);
+ if (this.onCallStatusChange) {
+ this.onCallStatusChange({ type, text });
+ }
+ }
+
+ handleIncomingCall(session) {
+ if (session.direction === "incoming") {
+ console.log("鏉ョ數:", session.remote_identity.uri.toString());
+ if (this.onIncomingCall) {
+ this.onIncomingCall(session);
+ }
+ }
+ }
}
export default new SipService();
--
Gitblit v1.9.3