消息队列七

 1 class Program 2     { 3         static void Main(string[] args) 4         { 5             do 6             { 7                 Produce(GetKafkaBroker(), getTopicName()); 8                 System.Threading.Thread.Sleep(3000); 9             } while (true);10         }11 12         private static void Produce(string broker, string topic)13         {14             var options = new KafkaOptions(new Uri(broker));15             var router = new BrokerRouter(options);16             var client = new Producer(router);17 18             var currentDatetime =DateTime.Now;19             var key = currentDatetime.Second.ToString();20             var events = new[] { new Message("Hello World " + currentDatetime, key) };21             client.SendMessageAsync(topic, events).Wait(1500);22             Console.WriteLine("Produced: Key: {0}. Message: {1}", key, events[0].Value.ToUtf8String());23 24             using (client) { }25         }26 27         private static string GetKafkaBroker()28         {29             string KafkaBroker = string.Empty;30             const string kafkaBrokerKeyName = "KafkaBroker";31 32             if (!ConfigurationManager.AppSettings.AllKeys.Contains(kafkaBrokerKeyName))33             {34                 KafkaBroker = "http://localhost:9092";35             }36             else37             {38                 KafkaBroker = ConfigurationManager.AppSettings[kafkaBrokerKeyName];39             }40             return KafkaBroker;41         }42         private static string getTopicName()43         {44             string TopicName = string.Empty;45             const string topicNameKeyName = "Topic";46 47             if (!ConfigurationManager.AppSettings.AllKeys.Contains(topicNameKeyName))48             {49                 throw new Exception("Key "" + topicNameKeyName + "" not found in Config file -> configuration/AppSettings");50             }51             else52             {53                 TopicName = ConfigurationManager.AppSettings[topicNameKeyName];54             }55             return TopicName;56         }57     }