使用SIP巫术C＃邀请请求

问题描述

我正在尝试使用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);
            }
        }

更新：我想使用Janus Gateway的SDP和接收方SDP将SIP INVITE消息发送到Asterisk服务器，如图所示：

Diagram 1

Diagram 2

解决方法

下面是如何执行此操作的示例（请注意，我的示例使用的是最新版本的sipsorcery代码，而您可能使用的是较早版本）。

但这是处理SIP呼叫的非常简便的方法。理想情况下，您应该使用SIPUserAgent类，它包装了较低层的逻辑：

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

您正在尝试使用最低级别的SIPRequest / SIPResponse原语，并且将不得不做很多额外的工作。例如，您需要发送ACK请求，处理信息（Try / Ring响应），处理重传，处理其他各种错误响应，检测重复的响应等。SIPUserAgent已经为您完成了所有这一切。 / p>

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:[e-mail]";

        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,null),new SIPFromHeader(null,new SIPURI(USERNAME,SERVER,CallProperties.CreateNewTag()),CallProperties.CreateNewTag())
            );
    }
}