使用Sorcery c#邀请请求

Question

我正在尝试使用sip魔法示例来发送和接收对我的服务器的请求和响应。我使用SIPRequest.SendRequestAsync(sipRequest)，但是响应始终是401个未经授权的

    private SIPTransport _sipTransport;
    private SIPRequest sipRequest;
    
    public SIPTransportLayer()
            {
                // Configure the SIP transport layer.
            }
    
    public async Task<SocketError> SendInviteRequestAsync()
            {
                SIPURI uri = SIPURI.ParseSIPURI("sip:" + "6005" + "@10.100.1.29:5060");
    
                //Creat SIP Request
                sipRequest = _sipTransport.GetRequest(
                    SIPMethodsEnum.INVITE,
                    uri,
                    new SIPToHeader(
                        null,
                        new SIPURI(uri.User, uri.Host, null, uri.Scheme, SIPProtocolsEnum.udp),
                        null
                        ),
                    );
                sipRequest.Header.From = new SIPFromHeader(USERNAME, uri_From, "tag");
    
                //Send request
                return await _sipTransport.SendRequestAsync(sipRequest);
            }

我正在尝试添加身份验证

private void _sipTransport_SIPTransportResponseReceived(SIPEndPoint localSIPEndPoint, SIPEndPoint remoteEndPoint, SIPResponse sipResponse)
        {
            if (sipResponse.StatusCode == 401 && sipResponse.Header.CSeqMethod == SIPMethodsEnum.INVITE)
            {
                //Resubscribe with Digist
                //SIP Header
                sipRequest.Header.CSeq++;
                sipRequest.Header.CallId = Guid.NewGuid().ToString();
                sipRequest.Header.AuthenticationHeader = sipResponse.Header.AuthenticationHeader;
                sipRequest.Header.Expires = 120;

                //SIP Authenticate
                SIPAuthorisationDigest authDigest = sipResponse.Header.AuthenticationHeader.SIPDigest;
                authDigest.SetCredentials(USERNAME, PASSWORD, DOMAIN, SIPMethodsEnum.INVITE.ToString());
                sipRequest.Header.AuthenticationHeader = new SIPAuthenticationHeader(authDigest);
                sipRequest.Header.AuthenticationHeader.SIPDigest.Response = authDigest.Digest;

                //Send request
                _sipTransport.SendRequestAsync(sipRequest);
            }
        }

SDP :我想用网关的SDP和接收方的向星号服务器发送SIP消息：

图1

图2

Answer 1

下面是一个如何做到这一点的示例(注意，我的示例使用的是最新版本的耗散代码，而您可能使用的是早期版本)。

但这是处理SIP调用的一种非常有效的方法。理想情况下，您应该使用SIPUserAgent类，它封装了较低级别的逻辑：

SIPUserAgent -> SIPClientUserAgent -> UACInviteTransaction -> SIPRequest/SIPResponse

您正在尝试使用最低级别的SIPRequest/SIPResponse原语，并且需要做很多额外的工作。例如，您需要发送ACK请求、处理信息(尝试/铃声响应)、处理重传、处理各种其他错误响应、检测重复响应等。SIPUserAgent已经为您完成了所有这些工作。

using System;
using System.Net.Sockets;
using System.Threading.Tasks;
using SIPSorcery.SIP;

namespace SIPInviteAuthentication
{
    class Program
    {
        static string USERNAME = "username";
        static string PASSWORD = "password";
        static string SERVER = "some.server.com";
        static string DST = "sip:1234@some.server.com";

        static SIPTransport _sipTransport;
        static bool _authRequestSent;

        static async Task Main()
        {
            _sipTransport = new SIPTransport();
            _sipTransport.SIPTransportResponseReceived += SIPTransportResponseReceived;

            await SendInviteRequestAsync();

            Console.ReadLine();
        }

        static Task<SocketError> SendInviteRequestAsync()
        {
            SIPURI dstUri = SIPURI.ParseSIPURIRelaxed(DST);
            return _sipTransport.SendRequestAsync(GetInviteRequest(dstUri));
        }

        static Task SIPTransportResponseReceived(SIPEndPoint localSIPEndPoint, SIPEndPoint remoteEndPoint, SIPResponse sipResponse)
        {
            if (sipResponse.Header.CSeqMethod == SIPMethodsEnum.INVITE && sipResponse.StatusCode >= 200)
            {
                if(sipResponse.Status == SIPResponseStatusCodesEnum.Ok)
                {
                    Console.WriteLine($"Authorisation successful.");
                }
                else if(sipResponse.Status == SIPResponseStatusCodesEnum.Unauthorised && !_authRequestSent)
                {
                    _authRequestSent = true;

                    SIPURI dstUri = SIPURI.ParseSIPURIRelaxed(DST);

                    // Resend INVITE with credentials.
                    SIPAuthorisationDigest digest = sipResponse.Header.AuthenticationHeader.SIPDigest;
                    digest.SetCredentials(USERNAME, PASSWORD, DST, SIPMethodsEnum.INVITE.ToString());

                    SIPRequest authInviteRequest = GetInviteRequest(dstUri);
                    authInviteRequest.Header.AuthenticationHeader = new SIPAuthenticationHeader(digest);
                    authInviteRequest.Header.AuthenticationHeader.SIPDigest.Response = digest.Digest;

                    return _sipTransport.SendRequestAsync(authInviteRequest);
                }
                else
                {
                    Console.WriteLine($"Authorisation failed with {sipResponse.Status}.");
                }
            }

            return Task.CompletedTask;
        }

        static SIPRequest GetInviteRequest(SIPURI dstUri) =>
             SIPRequest.GetRequest(
                SIPMethodsEnum.INVITE,
                dstUri,
                new SIPToHeader(null, dstUri, null),
                new SIPFromHeader(null, new SIPURI(USERNAME, SERVER, CallProperties.CreateNewTag()), CallProperties.CreateNewTag())
            );
    }
}