是否可以將未使用TLS加密的AMQP數據包/遙測發送到Azure事件中心?將AMQP遙測發送到未使用TLS加密的Azure事件中心
我想這樣做的原因是要確切瞭解未加密的AMQP數據包的外觀。
我曾嘗試下面的代碼(見amqpTransSetting.UseSslStreamSecurity =假,但它仍然加密通信。
var amqpTransSetting = new AmqpTransportSettings();
amqpTransSetting.UseSslStreamSecurity = false;
var cs = @"Endpoint=sb://companyname-ns.servicebus.windows.net/;SharedAccessKeyName=EventHubPublisher;SharedAccessKey=84EHa5NNllnZBzH5ksogvNfhMWtIokdTdjxXXXXXXX=";
var builder = new ServiceBusConnectionStringBuilder(cs)
{
TransportType = TransportType.Amqp,
};
var client = EventHubClient.CreateFromConnectionString(builder.ToString(), "companyname-eh");
int sentCount = sendCount;
string infoText;
for (int i = 0; i < sendCount; i++)
{
try
{
if (MessageType.Text == "Fake Sensor")
{
infoText = "Sent using AMQP protocol";
}
else
{
infoText = "Sent using AMQP protocol";
}
Random rnd = new Random();
int intTemp = rnd.Next(15, 25);
int intHum = rnd.Next(50, 80);
var e = new Event
{
MessageType = MessageType.Text,
Temp = intTemp,
Humidity = intHum,
Location = Location.Text,
Room = Room.Text,
Info = infoText
};
var serializedString = JsonConvert.SerializeObject(e);
var data = new EventData(Encoding.UTF8.GetBytes(serializedString))
{
PartitionKey = rnd.Next(6).ToString()
};
// Set user properties if needed
data.Properties.Add("Type", "Telemetry_" + DateTime.Now.ToLongTimeString());
await client.SendAsync(data).ConfigureAwait(false);
}
catch (Exception exp)
{
Console.WriteLine("Error on send: " + exp.Message);
sentCount--;
}
我建議問你想達到什麼新的問題(或修改這一個)。從CO這聽起來像你可能會很滿意HTTP接口(不是我曾經使用它)。如果您希望有大量的嵌入式設備,但不是來自任何單個設備的特別高的音量(即每個設備每秒幾個很好),它應該是較輕的重量,並且每個集線器的AMQP連接數有限制。 – cacsar