338 lines
14 KiB
C#
338 lines
14 KiB
C#
|
using DevExpress.XtraEditors;
|
|||
|
|
using System;
|
|||
|
|
using System.Net;
|
|||
|
|
using System.Net.Sockets;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading;
|
|||
|
|
using System.Windows.Forms;
|
|||
|
|
using HL_FristAidPlatform_Public;
|
|||
|
|
|
|||
|
|
|
|||
|
|
namespace HL_FristAidPlatform_MultiSystemPublic
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 专家会诊
|
|||
|
|
/// </summary>
|
|||
|
|
public partial class Form_Consultation : XtraForm
|
|||
|
|
{
|
|||
|
|
#region 变量
|
|||
|
|
Socket clientSocket = null;
|
|||
|
|
static bool isListen = true;
|
|||
|
|
Thread thDataFromServer;
|
|||
|
|
/// <summary>
|
|||
|
|
/// 服务器IP地址
|
|||
|
|
/// </summary>
|
|||
|
|
IPAddress ipAddress;
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 专家会诊服务端部署IP
|
|||
|
|
/// </summary>
|
|||
|
|
private string Config101 = PublicClassForDataBase.Config101;
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 当前用户名
|
|||
|
|
/// </summary>
|
|||
|
|
private string Cur_UserName = string.Empty;
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
public Form_Consultation()
|
|||
|
|
{
|
|||
|
|
InitializeComponent();
|
|||
|
|
ipAddress = IPAddress.Loopback;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 窗体加载
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="sender"></param>
|
|||
|
|
/// <param name="e"></param>
|
|||
|
|
private void Form_Consultation_Load(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
txt_ServerIP.Text = Config101;
|
|||
|
|
txt_UserName.Text = Cur_UserName = Information.User.FullName;
|
|||
|
|
//连接服务
|
|||
|
|
Connect(Config101);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 发生消息
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="sender"></param>
|
|||
|
|
/// <param name="e"></param>
|
|||
|
|
private void btn_Send_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
SendMessage();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 发送消息
|
|||
|
|
/// </summary>
|
|||
|
|
private void SendMessage()
|
|||
|
|
{
|
|||
|
|
if (string.IsNullOrWhiteSpace(txt_EditMessages.Text.Trim()))
|
|||
|
|
{
|
|||
|
|
XtraMessageBox.Show("不能发生空白信息！", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
if (clientSocket != null && clientSocket.Connected)
|
|||
|
|
{
|
|||
|
|
byte[] bytesSend = Encoding.UTF8.GetBytes(txt_EditMessages.Text + "$");
|
|||
|
|
clientSocket.Send(bytesSend);
|
|||
|
|
txt_EditMessages.Text = "";
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
XtraMessageBox.Show("未连接服务器或者服务器已停止，请联系管理员！", "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 连接服务器
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="connectIp">要连接的服务器IP</param>
|
|||
|
|
private void Connect(string connectIp)
|
|||
|
|
{
|
|||
|
|
if (Cur_UserName.Length >= 17 && Cur_UserName.ToString().Trim().Substring(0, 17).Equals("Server has closed"))
|
|||
|
|
{
|
|||
|
|
XtraMessageBox.Show("该用户名中包含敏感词，请更换用户名后重试", "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (clientSocket == null || !clientSocket.Connected)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
|||
|
|
//参考网址： https://msdn.microsoft.com/zh-cn/library/6aeby4wt.aspx
|
|||
|
|
// Socket.BeginConnect 方法 (String, Int32, AsyncCallback, Object)
|
|||
|
|
//开始一个对远程主机连接的异步请求
|
|||
|
|
/* string host, 远程主机名
|
|||
|
|
* int port, 远程主机的端口
|
|||
|
|
* AsyncCallback requestCallback, 一个 AsyncCallback 委托，它引用连接操作完成时要调用的方法，也是一个异步的操作
|
|||
|
|
* object state 一个用户定义对象，其中包含连接操作的相关信息。 当操作完成时，此对象会被传递给 requestCallback 委托
|
|||
|
|
*/
|
|||
|
|
//如果txt_ServerIP里面有值，就选择填入的IP作为服务器IP，不填的话就默认是本机的
|
|||
|
|
if (!string.IsNullOrEmpty(connectIp))
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
ipAddress = IPAddress.Parse(connectIp);
|
|||
|
|
}
|
|||
|
|
catch
|
|||
|
|
{
|
|||
|
|
XtraMessageBox.Show("请在配置参数表正确配置参数101的属性！", "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
ipAddress = IPAddress.Loopback;
|
|||
|
|
}
|
|||
|
|
//IPAddress ipadr = IPAddress.Parse("192.168.1.100");
|
|||
|
|
clientSocket.BeginConnect(ipAddress, 8080, (args) =>
|
|||
|
|
{
|
|||
|
|
if (args.IsCompleted) //判断该异步操作是否执行完毕
|
|||
|
|
{
|
|||
|
|
byte[] bytesSend = new byte[4096];
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
txt_UserName.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
bytesSend = Encoding.UTF8.GetBytes(txt_UserName.Text.Trim() + "$"); //用户名，这里是刚刚连接上时需要传过去
|
|||
|
|
if (clientSocket != null && clientSocket.Connected)
|
|||
|
|
{
|
|||
|
|
clientSocket.Send(bytesSend);
|
|||
|
|
txt_UserName.Enabled = false; //设置为不能再改名字了
|
|||
|
|
txt_EditMessages.Focus(); //将焦点放在
|
|||
|
|
thDataFromServer = new Thread(DataFromServer);
|
|||
|
|
thDataFromServer.IsBackground = true;
|
|||
|
|
thDataFromServer.Start();
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
XtraMessageBox.Show("服务器已关闭", "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
|||
|
|
txt_ServerIP.ReadOnly = false;
|
|||
|
|
}
|
|||
|
|
}));
|
|||
|
|
txt_ServerIP.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
if (clientSocket != null && clientSocket.Connected)
|
|||
|
|
{
|
|||
|
|
txt_ServerIP.Enabled = false;
|
|||
|
|
}
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
catch
|
|||
|
|
{
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}, null);
|
|||
|
|
}
|
|||
|
|
catch (SocketException ex)
|
|||
|
|
{
|
|||
|
|
XtraMessageBox.Show(ex.ToString(), "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取服务器端的消息
|
|||
|
|
/// </summary>
|
|||
|
|
private void DataFromServer()
|
|||
|
|
{
|
|||
|
|
ShowMessages("连接到会诊服务器...");
|
|||
|
|
isListen = true;
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
while (isListen)
|
|||
|
|
{
|
|||
|
|
byte[] bytesFrom = new byte[4096];
|
|||
|
|
int len = clientSocket.Receive(bytesFrom);
|
|||
|
|
|
|||
|
|
string dataFromClient = Encoding.UTF8.GetString(bytesFrom, 0, len);
|
|||
|
|
if (!string.IsNullOrWhiteSpace(dataFromClient))
|
|||
|
|
{
|
|||
|
|
//如果收到服务器已经关闭的消息，那么就把客户端接口关了，免得出错，并在客户端界面上显示出来
|
|||
|
|
if (dataFromClient.ToString().Length >= 17 && dataFromClient.ToString().Substring(0, 17).Equals("Server has closed"))
|
|||
|
|
{
|
|||
|
|
clientSocket.Close();
|
|||
|
|
clientSocket = null;
|
|||
|
|
|
|||
|
|
txt_ReceiveMessages.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
txt_ReceiveMessages.Text += Environment.NewLine + "服务器已关闭";
|
|||
|
|
txt_ReceiveMessages.SelectionStart = txt_ReceiveMessages.Text.Length;
|
|||
|
|
txt_ReceiveMessages.ScrollToCaret();
|
|||
|
|
}));
|
|||
|
|
|
|||
|
|
txt_UserName.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
txt_UserName.Enabled = true;
|
|||
|
|
}));
|
|||
|
|
//重连当然可以换用户名啦
|
|||
|
|
|
|||
|
|
txt_ServerIP.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
txt_ServerIP.Enabled = true;
|
|||
|
|
}));
|
|||
|
|
|
|||
|
|
thDataFromServer.Abort();//这一句必须放在最后，不然这个进程都关了后面的就不会执行了
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (dataFromClient.StartsWith("#") && dataFromClient.EndsWith("#"))
|
|||
|
|
{
|
|||
|
|
string userName = dataFromClient.Substring(1, dataFromClient.Length - 2);
|
|||
|
|
BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
MessageBox.Show("用户名：[" + userName + "]已经存在，请尝试其他用户名并重试");
|
|||
|
|
|
|||
|
|
}));
|
|||
|
|
isListen = false;
|
|||
|
|
|
|||
|
|
txt_UserName.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
txt_UserName.Enabled = true;
|
|||
|
|
clientSocket.Send(Encoding.UTF8.GetBytes("$"));
|
|||
|
|
clientSocket.Close();
|
|||
|
|
clientSocket = null;
|
|||
|
|
}));
|
|||
|
|
txt_ServerIP.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
txt_ServerIP.Enabled = true;
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
//txt_UserName.Enabled = false; //当用户名唯一时才禁止再次输入用户名
|
|||
|
|
ShowMessages(dataFromClient);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (SocketException ex)
|
|||
|
|
{
|
|||
|
|
isListen = false;
|
|||
|
|
if (clientSocket != null && clientSocket.Connected)
|
|||
|
|
{
|
|||
|
|
//没有在客户端关闭连接，而是给服务器发送一个消息，在服务器端关闭连接
|
|||
|
|
//这样可以将异常的处理放到服务器。客户端关闭会让客户端和服务器都抛异常
|
|||
|
|
clientSocket.Send(Encoding.UTF8.GetBytes("$"));
|
|||
|
|
MessageBox.Show(ex.ToString());
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 显示消息
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="messages"></param>
|
|||
|
|
private void ShowMessages(string messages)
|
|||
|
|
{
|
|||
|
|
txt_ReceiveMessages.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
txt_ReceiveMessages.Text += Environment.NewLine + messages; // 在 Windows 环境中，C# 语言 Environment.NewLine == "\r\n" 结果为 true
|
|||
|
|
txt_ReceiveMessages.SelectionStart = txt_ReceiveMessages.Text.Length;
|
|||
|
|
txt_ReceiveMessages.ScrollToCaret();
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 窗体激活时鼠标焦点定位到消息框
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="sender"></param>
|
|||
|
|
/// <param name="e"></param>
|
|||
|
|
private void Form_Consultation_Activated(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
txt_EditMessages.Focus();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 聊天窗口关闭后
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="sender"></param>
|
|||
|
|
/// <param name="e"></param>
|
|||
|
|
private void Form_Consultation_FormClosed(object sender, FormClosedEventArgs e)
|
|||
|
|
{
|
|||
|
|
if (clientSocket != null && clientSocket.Connected)
|
|||
|
|
{
|
|||
|
|
clientSocket.Send(Encoding.UTF8.GetBytes("$"));
|
|||
|
|
ExitConnect();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 退出聊天
|
|||
|
|
/// </summary>
|
|||
|
|
private void ExitConnect()
|
|||
|
|
{
|
|||
|
|
if (clientSocket != null && clientSocket.Connected)
|
|||
|
|
{
|
|||
|
|
thDataFromServer.Abort();
|
|||
|
|
clientSocket.Send(Encoding.UTF8.GetBytes("$"));
|
|||
|
|
|
|||
|
|
clientSocket.Close();
|
|||
|
|
clientSocket = null;
|
|||
|
|
|
|||
|
|
txt_ReceiveMessages.BeginInvoke(new Action(() =>
|
|||
|
|
{
|
|||
|
|
txt_ReceiveMessages.Text += Environment.NewLine + "已断开与服务器的连接";
|
|||
|
|
txt_ReceiveMessages.SelectionStart = txt_ReceiveMessages.Text.Length;
|
|||
|
|
txt_ReceiveMessages.ScrollToCaret();
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 重新连接服务器
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="sender"></param>
|
|||
|
|
/// <param name="e"></param>
|
|||
|
|
private void btn_RefConnect_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
Connect(txt_ServerIP.Text.ToString());
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|