using Microsoft.ServiceBus;
using Microsoft.ServiceBus.Messaging;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace ServiceBusScribe
{class TextEventArgs :EventArgs{public ChatText ChatText{get; private set;}public TextEventArgs (ChatText chatText){ChatText = chatText;}}class ChatRoom{public event EventHandler<TextEventArgs> TextReceived;public string Name { get; private set; }TopicClient mTopicClient;SubscriptionClient mSubscriptionClient;//your servicebus namespace hereconst string mConString = "Endpoint=sb://[YourServiceBusName].servicebus.chinacloudapi.cn/;SharedAccessKeyName=[YourServiceBusKey]";public ChatRoom(string chatRoom, string userName){Name = chatRoom;NamespaceManager nm = NamespaceManager.CreateFromConnectionString(mConString);TopicDescription desc = new TopicDescription(chatRoom);desc.AutoDeleteOnIdle = TimeSpan.FromMinutes(10);if (!nm.TopicExists(chatRoom))//如果没有该Topic，则创建
                nm.CreateTopic(chatRoom);if (!nm.SubscriptionExists(chatRoom, userName))//如果有该Topic，则订阅
                nm.CreateSubscription(chatRoom, userName);mTopicClient = TopicClient.CreateFromConnectionString(mConString, chatRoom);mSubscriptionClient = SubscriptionClient.CreateFromConnectionString(mConString, chatRoom, userName);mSubscriptionClient.OnMessage((m) =>{var text = m.GetBody<ChatText>();if (TextReceived != null)TextReceived(this, new TextEventArgs(text));});}public void Send(string user, int color, string text){mTopicClient.Send(new BrokeredMessage(new ChatText(user, color, text)));}public void Close(){mSubscriptionClient.Close();mTopicClient.Close();}}
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Runtime.Serialization;namespace ServiceBusScribe
{[DataContract]class ChatText{[DataMember]public string User { get; set; }[DataMember]public string Text { get; set; }[DataMember]public int Color { get; set; }public ChatText(string user, int color, string text){User = user;Text = text;Color = color;}}}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;using System.Runtime.Serialization;namespace ServiceBusScribe
{class Program{static int linePos = 2;  //当前显示行的位置static int myColor = 1;  //为用户随机指定的颜色static Array mColors = Enum.GetValues(typeof(ConsoleColor));static void Main(string[] args){Random rand = new Random();myColor = rand.Next(0, mColors.Length);  //随机指定用户名颜色
            Console.Clear();Console.Write("请输入用户名:");string userName = Console.ReadLine();//输入新聊天室名，或者加入已有聊天室Console.Write("请输入聊天室名:");string chatRoom = Console.ReadLine();//聊天室界面
            Console.Clear();Console.Write(userName);Console.SetCursorPosition(Console.WindowWidth - chatRoom.Length, 0);Console.Write(chatRoom);Console.Write(new String('*', Console.WindowWidth));Console.SetCursorPosition(0, Console.WindowHeight - 4);Console.Write(new String('*', Console.WindowWidth));ChatRoom room = new ChatRoom(chatRoom, userName);room.TextReceived += room_TextReceived;while (true){setCursorAtBottom();var input = Console.ReadLine();if (string.IsNullOrEmpty(input))break;room.Send(userName, myColor, input);}room.Close();}static void setCursorAtBottom(){ //这个方法把光标放在屏幕底部，供用户输入新信息Console.SetCursorPosition(0, Console.WindowHeight - 3);Console.Write(new String(' ', Console.WindowWidth));Console.SetCursorPosition(0, Console.WindowHeight - 3);Console.Write("] ");}static void room_TextReceived(object sender, TextEventArgs e){if (linePos >= Console.WindowHeight - 4){for (int i = 2; i < Console.WindowHeight - 4; i++){Console.SetCursorPosition(0, i);Console.Write(new string(' ', Console.WindowWidth));}linePos = 2;}//显示接受到的新消息Console.SetCursorPosition(0, linePos);Console.ForegroundColor = (ConsoleColor)mColors.GetValue(e.ChatText.Color);Console.Write("[" + e.ChatText.User + "]:");Console.ForegroundColor = ConsoleColor.White;Console.Write(e.ChatText.Text);linePos++;setCursorAtBottom();}}
}