c# - 响应 Bargain Finder Max Compress c#

Question

早上好，我在 .net 中有一个解决方案，我调用 saber bargain finder max 的网络服务。现在我想下载压缩后的信息，但响应对象返回 null。我读到你必须调用接口(interface) IClientMessageInspector BeforeSendRequest 和 AfterReceiveReply 但我不知道如何进行。有人会有关于它的例子或解决方案吗？谢谢

Answer 1

服务的响应无法处理压缩响应，所以是的，您必须放置中间件以便在继续之前处理解压缩。

首先，您需要将 BFM WSDL 作为服务导入，而不是作为 Web 服务，因此:

1. 右键单击“服务引用”，然后单击“添加服务引用...”
2. 将 WSDL URL 粘贴到“地址:”下，然后单击“开始”
   • 建议:下载 WSDL 和相关架构，以便您可以修改它们，因为 .NET 在处理某些事情时存在一些问题，您可以手动修改这些事情。 Sabre has some covered here .
3. 根据您的喜好为服务命名，在本例中，我将其命名为BargainFinderMaxRQ_4_1_0_Srvc，在“命名空间:”下，然后单击“确定"

然后，我创建了 2 个类，一个将调用 BFM(“BFM_v410Service”)，另一个用于中间件(“BFMInspector”)。

让我们从 BFMInspector 开始:

// The inspector class has to implement both IClientMessageInspector and IEndpointBehavior interfaces
public class BFMInspector : IClientMessageInspector, IEndpointBehavior
{
    // This is the method to action after receiving a response from Sabre
    public void AfterReceiveReply(ref Message reply, object correlationState)
    {
        try
        {
            // Get compressed response from reply and load that into a byte array.
            XmlDictionaryReader bodyReader = reply.GetReaderAtBodyContents();
            bodyReader.ReadStartElement("CompressedResponse");
            byte[] bodyByteArray = bodyReader.ReadContentAsBase64();

            // Create some helper variables
            StringBuilder uncompressed = new StringBuilder();
            String xmlString = "";
            XmlDocument xmlPayload = new XmlDocument();

            // Load the byte array into memory
            using (MemoryStream memoryStream = new MemoryStream(bodyByteArray))
            {
                // Unzip the Stream
                using (GZipStream gZipStream = new GZipStream(memoryStream, CompressionMode.Decompress))
                {
                    byte[] buffer = new byte[1024];
                    int readBytes;

                    // Unzips character by character
                    while ((readBytes = gZipStream.Read(buffer, 0, buffer.Length)) != 0)
                    {
                        for (int i = 0; i < readBytes; i++)
                            // Append all characters to build the response
                            uncompressed.Append((char)buffer[i]);
                    }
                }

                xmlString = uncompressed.ToString();
                xmlString = xmlString.Replace("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>", "");
            }

            // Convert the string into an XML
            xmlPayload.LoadXml(xmlString);

            // Create a new Message, which is what will substitute what was returned by Sabre
            Message tempMessage = Message.CreateMessage(reply.Version, null, xmlPayload.ChildNodes[0]);

            tempMessage.Headers.CopyHeadersFrom(reply.Headers);
            tempMessage.Properties.CopyProperties(reply.Properties);

            MessageBuffer bufferOfFault = tempMessage.CreateBufferedCopy(Int32.MaxValue);

            // Replace the reply with the new Message
            reply = bufferOfFault.CreateMessage();
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }

    public object BeforeSendRequest(ref Message request, IClientChannel channel)
    {
        // Nothing is done here, so we simply return null
        return null;
    }

    public void AddBindingParameters(ServiceEndpoint endpoint, BindingParameterCollection bindingParameters)
    {
        // Nothing done
    }

    public void ApplyClientBehavior(ServiceEndpoint endpoint, ClientRuntime clientRuntime)
    {
        // Add "this" as an endpoint to be inspected
        clientRuntime.MessageInspectors.Add(this);
    }

    public void ApplyDispatchBehavior(ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher)
    {
        // Nothing done
    }

    public void Validate(ServiceEndpoint endpoint)
    {
        // Nothing done
    }
}

现在，BFM_v410Service:

// BFM calling class
public class BFM_v410Service
{
    // The constructor and CreateRequest simeply create a complete request
    private BargainFinderMaxRQRequest service;
    private OTA_AirLowFareSearchRQ request;
    public OTA_AirLowFareSearchRS response;
    private string endpoint;

    public BFM_v410Service(string token, string pcc, string convId, string endpoint)
    {
        CreateRequest(pcc, true);
        this.endpoint = endpoint;

        service = new BargainFinderMaxRQRequest()
        {
            MessageHeader = new BargainFinderMaxRQ_3_4_0_Srvc.MessageHeader()
            {
                From = new From()
                {
                    PartyId = new PartyId[]
                {
                    new PartyId()
                    {
                        Value = pcc
                    }
                }
                },
                To = new To()
                {
                    PartyId = new PartyId[]
                {
                    new PartyId()
                    {
                        Value = endpoint
                    }
                }
                },
                ConversationId = convId,
                CPAId = pcc,
                Service = new Service()
                {
                    Value = "BargainFinderMaxRQ"
                },
                Action = "BargainFinderMaxRQ",
                MessageData = new MessageData()
                {
                    Timestamp = DateTime.UtcNow.ToString("yyyy-MM-ddTHH:mm:ssK")
                }
            },
            OTA_AirLowFareSearchRQ = request,
            Security = new Security()
            {
                BinarySecurityToken = token
            }
        };
    }

    private void CreateRequest(string pcc, bool compressed)
    {
        request = new OTA_AirLowFareSearchRQ()
        {
            Version = "3.4.0",
            POS = new SourceType[]
            {
                new SourceType()
                {
                    PseudoCityCode = pcc,
                    RequestorID = new UniqueID_Type()
                    {
                        ID = "1",
                        Type = "1",
                        CompanyName = new CompanyNameType()
                        {
                            Code = "TN",
                            Value = "TN"
                        }
                    }
                }
            },
            OriginDestinationInformation = new OTA_AirLowFareSearchRQOriginDestinationInformation[]
            {
                new OTA_AirLowFareSearchRQOriginDestinationInformation()
                {
                    RPH = "1",
                    Item = "2018-09-21T11:00:00",
                    ItemElementName = ItemChoiceType.DepartureDateTime,
                    OriginLocation = new OriginDestinationInformationTypeOriginLocation()
                    {
                        LocationCode = "MVD"
                    },
                    DestinationLocation = new OriginDestinationInformationTypeDestinationLocation()
                    {
                        LocationCode = "KRK"
                    }
                },
                new OTA_AirLowFareSearchRQOriginDestinationInformation()
                {
                    RPH = "2",
                    Item = "2018-09-28T11:00:00",
                    ItemElementName = ItemChoiceType.DepartureDateTime,
                    OriginLocation = new OriginDestinationInformationTypeOriginLocation()
                    {
                        LocationCode = "KRK"
                    },
                    DestinationLocation = new OriginDestinationInformationTypeDestinationLocation()
                    {
                        LocationCode = "MVD"
                    }
                }
            },
            TravelerInfoSummary = new TravelerInfoSummaryType()
            {
                AirTravelerAvail = new TravelerInformationType[]
                {
                    new TravelerInformationType()
                    {
                        PassengerTypeQuantity = new PassengerTypeQuantityType[]
                        {
                            new PassengerTypeQuantityType()
                            {
                                Code = "ADT",
                                Quantity = "1"
                            }
                        }
                    }
                }
            },
            TPA_Extensions = new OTA_AirLowFareSearchRQTPA_Extensions()
            {
                IntelliSellTransaction = new TransactionType()
                {
                    RequestType = new TransactionTypeRequestType()
                    {
                        Name = "50ITINS"
                    },
                    CompressResponse = new TransactionTypeCompressResponse()
                    {
                        Value = compressed
                    }
                }
            }
        };
    }

    public void Execute()
    {
        try
        {
            // Instanciate the Inspector
            BFMInspector inspector = new BFMInspector();

            // Select the URL you'll be sending the request. I've passed this as a parameter in the constructor
            EndpointAddress url = new EndpointAddress(new Uri(endpoint));

            // Create a binding, with a couple of characteristics, because of the size of the response
            Binding binding = new BasicHttpsBinding()
            {
                MaxReceivedMessageSize = Int32.MaxValue,
                MaxBufferSize = Int32.MaxValue
            };

            // Create the executable the BargainFinderMaxPortTypeClient variable, which will allow me to call the service
            BargainFinderMaxPortTypeClient execute = new BargainFinderMaxPortTypeClient(binding, url);

            // Add the middleware. Here's where ApplyClientBehavior is called behind the scene and adds itself
            execute.Endpoint.EndpointBehaviors.Add(inspector);

            // Call BFM and successfully get the response as an OTA_AirLowFareSearchRS object
            response = execute.BargainFinderMaxRQ(ref service.MessageHeader, ref service.Security, request);
            Console.WriteLine(response);
        }
        catch(Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }
}

然后，只需从控制台应用程序调用它:

static void Main(string[] args)
{
    System.Net.ServicePointManager.SecurityProtocol = System.Net.SecurityProtocolType.Tls12;

    string token = @"Shared/IDL:IceSess\/SessMgr:1\.0.IDL/Common/!ICESMS\/RESA!ICESMSLB\/RES.LB!-3146624380791354996!413892!0!1!E2E-1";
    string pcc = "XXXX";
    string convId = "HERE GOES YOUR CONVERSATION ID";
    string endpoint = "https://webservices.havail.sabre.com";

    BFM_v410Service bfm340 = new BFM_v410Service(token, pcc, convId, endpoint);
    bfm410.Execute();
}

希望这对您有所帮助!