软件工程 2016.7.4日报

　　今天我进行的主要工作包括了完成服务器端功能的搭建，以及客户端socket通信功能架构的搭建以及部分功能的实现。

　　对服务器端，在周五的时候我对于接受消息、处理消息部分的功能还没有实现，今天将代码补全，构建出了一个较完善的服务端代码。

　　今天具体实现的代码如下：

　　　　主要实现了检查本地是否包含用户所上的全部课程的聊天室，返回特定聊天室的聊天记录给用户，向特定聊天室记录文件中添加吐槽，以及移除在线好友，处理非法信息等。

　　　　在实现的过程中运用的主要技术包括C#文件操作、JSON封装/解析数据、socket TCP通信等。

  1         #region --- Check Room List ---
  2         /// <summary>
  3         ///     Check the existence of every room in room list received from client
  4         /// </summary>
  5         /// <param name="msg">string of room list</param>
  6         private void CheckRoomList(string s_roomList)
  7         {
  8             // TODO : check the existence of chat file of each room
  9             List<string> roomList = (List<string>)JsonConvert.DeserializeObject(s_roomList, typeof(List<string>));
 10 
 11             foreach (string room in roomList)
 12             {
 13                 string roomFile = room + ".txt";
 14                 if (!File.Exists(@roomFile))
 15                 {
 16                     FileStream fs = new FileStream(roomFile, FileMode.Create);
 17                     fs.Close();
 18                 }                   
 19             }
 20 
 21         }
 22         #endregion
 23 
 24         #region --- Get Room Message ---
 25         /// <summary>
 26         ///     get the history message of the specific chat room
 27         /// </summary>
 28         /// <param name="clientIP">the client IP</param>
 29         /// <param name="msg">the room ID</param>
 30         private void GetRoomMsg(string clientIP, string roomId)
 31         {
 32             // TODO : get the history of specific chat room
 33             string roomFile = roomId + ".txt";
 34 
 35             List<string> msgList = new List<string>();
 36 
 37             String sendMsg = "";
 38 
 39             if (File.Exists(@roomFile))
 40             {
 41                 StreamReader sr = new StreamReader(roomFile, Encoding.Default);
 42                 
 43                 String lineMsg;
 44                 while ((lineMsg = sr.ReadLine()) != null)
 45                     msgList.Add(lineMsg);
 46                 sendMsg = JsonConvert.SerializeObject(msgList);
 47             }
 48             else
 49             {
 50                 FileStream fs = new FileStream(roomFile, FileMode.Create);
 51                 fs.Close();
 52             }
 53 
 54             SendMessage(clientIP, REQUEST_ROOM_MSG, sendMsg);
 55         }
 56         #endregion
 57 
 58         #region --- Add Message To File ---
 59         /// <summary>
 60         ///     put the message into the specific room
 61         /// </summary>
 62         /// <param name="clientIP">the client IP</param>
 63         /// <param name="msg">the string include the room id and received message</param>
 64         private void AddMsgToFile(string clientIP, string msg)
 65         {
 66             // TODO : put the message into the specific room
 67             MsgHandler msgHandler = (MsgHandler)JsonConvert.DeserializeObject(msg, typeof(MsgHandler));
 68 
 69             string roomFile = msgHandler.roomId + ".txt";
 70 
 71             FileStream fs = new FileStream(roomFile, FileMode.OpenOrCreate);
 72             StreamWriter sw = new StreamWriter(fs);
 73             sw.WriteLine(msgHandler.msg);
 74             sw.Close();
 75             fs.Close();
 76         }
 77         #endregion
 78 
 79         #region --- Remove Offline User ---
 80         /// <summary>
 81         ///     remove off line user
 82         /// </summary>
 83         /// <param name="clientIP">the client IP</param>
 84         private void RemoveOfflineUser(string clientIP)
 85         {
 86             Console.WriteLine("User IP : " + clientIP + " has went off line.");
 87 
 88             if (dictSocket.ContainsKey(clientIP))
 89             {
 90                 dictSocket[clientIP].Close();
 91                 dictSocket.Remove(clientIP);
 92             }               
 93 
 94             if (dictThread.ContainsKey(clientIP))
 95             {
 96                 Thread tmp = dictThread[clientIP];
 97                 dictThread.Remove(clientIP);
 98                 tmp.Abort();
 99             }
100                 
101         }
102         #endregion
103 
104         #region --- Invalid Message ---
105         /// <summary>
106         ///     Handle the situation of invalid message
107         /// </summary>
108         /// <param name="clientIP">the client ip</param>
109         private void InvalidMsg(string clientIP)
110         {
111             // TODO : send invalid warning to client
112             SendMessage(clientIP, INVALID_MESSAGE, "");
113         }
114         #endregion

　　　　在客户端我构建了一个程序的架子，并且实现了部分功能。留下没有实现的功能涉及到和UI端的交互问题，目前我还没有想的比较清楚要如何完成这一部分的交互。因为我client在收到消息时是不太容易能够让UI端知道　的，所以要通知UI端对控件内容作更改目前也没有比较好的解决方法。目前想到的方法就是我这边直接去操作UI端的控件，不必通知UI，由我这边直接对空间内容进行修改。但这个方法总觉得不理想，如果有人能够对此类问题有一个较好的解决方法的话请留言告诉我，谢谢！

　　　　今天在UI端实现的代码主要如下：

  1         #region --- Connect To The Server ---
  2         /// <summary>
  3         ///     Connect to the server
  4         /// </summary>
  5         public Client()
  6         {
  7             // get IP address
  8             IPAddress address = IPAddress.Parse(ipAddr);
  9             // create the endpoint
 10             IPEndPoint endpoint = new IPEndPoint(address, port);
 11             // create the socket, use IPv4, stream connection and TCP protocol
 12             socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 13             try
 14             {
 15                 // Connect to the Server
 16                 socketClient.Connect(endpoint);
 17 
 18                 threadClient = new Thread(ReceiveMsg);
 19                 threadClient.IsBackground = true;
 20                 threadClient.Start();
 21             }
 22             catch (SocketException se)
 23             {
 24                 MessageBox.Show("[SocketError]Connection failed: " + se.Message);
 25             }
 26             catch (Exception ex)
 27             {
 28                 MessageBox.Show("[Error]Connection failed: " + ex.Message);
 29             }
 30         }
 31         #endregion
 32 
 33         #region --- Check Room List ---
 34         /// <summary>
 35         ///     check room list
 36         /// </summary>
 37         /// <param name="roomList"></param>
 38         public void CheckRoomList(List<string> roomList)
 39         {
 40             string s_roomList = JsonConvert.SerializeObject(roomList);
 41 
 42             SendMsg(CHECK_ROOM_LIST, s_roomList);
 43         }
 44         #endregion
 45 
 46         #region --- Add New Message ---
 47         /// <summary>
 48         ///     add new message
 49         /// </summary>
 50         /// <param name="roomId"></param>
 51         /// <param name="msg"></param>
 52         public void AddNewMsg(string roomId, string msg)
 53         {
 54             MsgHandler msgHandler = new MsgHandler(roomId, msg);
 55             string sendMsg = JsonConvert.SerializeObject(msgHandler);
 56             
 57             SendMsg(SEND_MSG, sendMsg);
 58         }
 59         #endregion
 60 
 61         #region --- Off Line ---
 62         /// <summary>
 63         ///     go off line
 64         /// </summary>
 65         public void GoOffLine()
 66         {
 67             SendMsg(DISCONNECT, "");
 68         }
 69         #endregion
 70 
 71         #region --- Send Message ---
 72         /// <summary>
 73         ///     Send Message
 74         /// </summary>
 75         /// <param name="flag">msg type</param>
 76         /// <param name="msg">message</param>
 77         private void SendMsg(byte flag, string msg)
 78         {
 79             try
 80             {
 81                 byte[] arrMsg = Encoding.UTF8.GetBytes(msg);
 82                 byte[] sendArrMsg = new byte[arrMsg.Length + 1];
 83 
 84                 // set the msg type
 85                 sendArrMsg[0] = flag;
 86                 Buffer.BlockCopy(arrMsg, 0, sendArrMsg, 1, arrMsg.Length);
 87 
 88                 socketClient.Send(sendArrMsg);
 89             }
 90             catch (SocketException se)
 91             {
 92                 Console.WriteLine("[SocketError] send message error : {0}", se.Message);
 93             }
 94             catch (Exception e)
 95             {
 96                 Console.WriteLine("[Error] send message error : {0}", e.Message);
 97             }
 98         }
 99         #endregion
100 
101         #region --- Receive Message ---
102         /// <summary>
103         ///     receive message
104         /// </summary>
105         private void ReceiveMsg()
106         {
107             while (true)
108             {
109                 // define a buffer for received message
110                 byte[] arrMsg = new byte[1024 * 1024 * 2];
111 
112                 // length of message received
113                 int length = -1;
114 
115                 try
116                 {
117                     // get the message
118                     length = socketClient.Receive(arrMsg);
119 
120                     // encoding the message
121                     string msgReceive = Encoding.UTF8.GetString(arrMsg, 1, length-1);
122 
123                     if (arrMsg[0] == SEND_MSG)
124                     {
125 
126                     }
127                     else if (arrMsg[0] == IS_RECEIVE_MSG)
128                     {
129 
130                     }
131                     else if (arrMsg[0] == IS_NOT_RECEIVE_MSG)
132                     {
133 
134                     }
135                     else if (arrMsg[0] == INVALID_MESSAGE)
136                     {
137 
138                     }
139                     else
140                     {
141 
142                     }
143 
144                 }
145                 catch (SocketException se)
146                 {
147                     //MessageBox.Show("【错误】接收消息异常：" + se.Message);
148                     return;
149                 }
150                 catch (Exception e)
151                 {
152                     //MessageBox.Show("【错误】接收消息异常：" + e.Message);
153                     return;
154                 }
155             }
156         }
157         #endregion

　　　　在ReceiveMsg中那几个if else中空出来的部分就是涉及到与UI端交互的部分。

　　　　除此之外，今天晚上在和组长进行讨论时，发现对于服务端在操作文件时要为每个文件加一个锁，这样才能保证数据的同步。所以这也是之后需要修改的地方。