|
1 2 |
//通知一个或多个正在等待的线程已发生事件。 ManualResetEvent manager = new ManualResetEvent(false); |
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 |
//负责监听的套接字 private Socket socketServer; /// <summary> /// 启动服务 /// </summary> private void CreateSocketService() { try { //获取IP var address = IPAddress.Parse(txtIP.Text.Trim()); //创建一个包含ip port 的网络节点对象 var ipPoint = new IPEndPoint(address, Convert.ToInt32(txtPort.Text.Trim())); //创建一个套接字socket,参数(IP4寻址协议,流式连接,使用TCP协议传输数据) socketServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //将负责监听的套接字绑定到唯一的IP和端口上 socketServer.Bind(ipPoint); //设置监听队列的长度，同时100个队列 socketServer.Listen(100); //线程开始监听客户端的请求 threadService = new Thread(StartSocketService); //设置线程为后台线程 threadService.IsBackground = true; //启动线程 threadService.Start(); //显示消息 ShowMsg("服务器监听开启成功!"); } catch (Exception e) { ShowMsg(e.Message); } } |
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 |
/// <summary> /// 启动服务监听 /// </summary> private void StartSocketService() { while (true) { try { //将事件状态设置为非终止状态，导致线程阻止 manager.Reset(); //开始监听客户端的连接请求 var args = new SocketAsyncEventArgs(); args.Completed += args_Completed; socketServer.AcceptAsync(args); //WaitHandle receives a signal." data-guid="dd8c3ab0d5ce03487bc8a650ef1c15c8">阻止当前线程，直到当前 WaitHandle 收到信号。 manager.WaitOne(); } catch (Exception ex) { ShowMsg(ex.Message); break; } } } |
|
1 2 3 4 5 6 7 8 9 |
void args_Completed(object sender, SocketAsyncEventArgs e) { //监听完成客户端的请求,一但监听到返回新的套接字 var clientSocket = e.AcceptSocket; //启动线程获取客户端发来的消息 if (clientSocket == null) return; //开始接受消息....... //该函数未写完，第二篇补全 } |
|
1 2 3 4 5 |
void ShowMsg(string message) { //显示消息 txtConneMsg.AppendText("\r\n" + DateTime.Now + "\r\n\r\n" + message + "\r\n"); } |
ok 服务监听就启动成功了,正等待客户端连接。
|
1 |
ManualResetEvent reviceManager = new ManualResetEvent(false); |
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
public void args_Completed(object sender, SocketAsyncEventArgs e) { //监听完成客户端的请求,一但监听到返回新的套接字 var clientSocket = e.AcceptSocket; if (clientSocket == null) return; //启动线程获取客户端发来的消息 //这部分为接收消息 var t = new Thread(GetClientMsg); //设置线程为后台线程 t.IsBackground = true; //启动线程 t.Start(clientSocket); //显示信息 ShowMsg(clientSocket.RemoteEndPoint + "上线了"); //将事件状态设置为终止状态，允许一个或多个等待线程继续 manager.Set(); } |
建议对照 C# Socket基础(一)之启动异步服务侦听 来看。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
private void GetClientMsg(object socket) { var socketClient = socket as Socket; if (socketClient == null) return; while (true) { try { reviceManager.Reset(); var bytes = new byte[1024 * 1024 * 4]; var receiveArgs = new SocketAsyncEventArgs(); //设置缓冲区 receiveArgs.SetBuffer(bytes, 0, bytes.Length); receiveArgs.Completed += receiveArgs_Completed; //开始异步接收 socketClient.ReceiveAsync(receiveArgs); reviceManager.WaitOne(); } catch (Exception ex) { //显示异常消息 ShowMsg(ex.Message); } } } |
接收消息完成回调事件
|
1 2 3 4 5 6 7 |
void receiveArgs_Completed(object sender, SocketAsyncEventArgs e) { var socketClient = sender as Socket; var bytes = e.Buffer; ShowMsg(socketClient.RemoteEndPoint + "说:" + System.Text.Encoding.UTF8.GetString(bytes)); reviceManager.Set(); } |
又与大家见面，看不懂的随时问。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 |
private Thread threadClient;//客户端线程 private Socket socketClient;//客户端套接字 /// <summary> /// 创建套接字连接到服务端 /// </summary> private void CreateSocketConnection() { try { //创建一个客户端的套接字 参数(IP4寻址协议,流连接方式,TCP数据传输协议) socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //获取IP IPAddress address = IPAddress.Parse(txtIP.Text.Trim()); //创建一个包含IP和端口号的网络节点对象 IPEndPoint ipPoint = new IPEndPoint(address, Convert.ToInt32(txtPort.Text.Trim())); // 连接服务端 socketClient.Connect(ipPoint); //创建一个线程,接受服务端发来的数据 threadClient = new Thread(ReceiveService); //设置线程为后台线程 threadClient.IsBackground = true; //启动线程连接服务端 threadClient.Start(); //显示消息 ShowMsg("与服务器" + txtIP.Text.Trim() + ":" + txtPort.Text + "成功建立连接！"); } catch (Exception) { ShowMsg(txtIP.Text.Trim() + ":" + txtPort.Text + "服务器未启动！"); } } |
客户端接收消息
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
private void ReceiveService() { while (true) { try { int num = -1; var b = new byte[1024 * 1024 * 4]; int length = socketClient.Receive(b); var msg = System.Text.Encoding.UTF8.GetString(b,0,length); ShowMsg(socketClient.RemoteEndPoint.ToString() + "对您: " + msg); } catch (Exception ex) { ShowMsg(ex.Message); break; } } } |
|
1 2 3 4 |
private void ShowMsg(string msg) { txtConneMsg.AppendText("\r\n" + DateTime.Now + "\r\n\r\n" + msg + "\r\n"); } |
客户端: 服务器: 客户端接收到消息: private Socket socketClient;//客户端套接字,关于实例化请参考C# Socket基础(三)之客户端连接服务器和接收消息 客户端发送消息
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 |
/// <summary> /// 发送数据到服务端 /// </summary> private void Send() { if (socketClient == null) { ShowMsg("服务器未启动！"); return; } byte[] b = System.Text.Encoding.UTF8.GetBytes(txtSend.Text.Trim()); //客户端向服务器发送消息 socketClient.Send(b); //清空文本 ShowMsg("您对" + socketClient.RemoteEndPoint.ToString() + "说：" + txtSend.Text.Trim()); txtSend.Text = ""; } |
关于 ShowMsg(string message);是自定义的函数，在C# Socket基础(一)之启动异步服务侦听 好了，到这里就要告一段落了,实现了基本的客户端和服务器采用TCP协议通信。 看看效果吧: 客户端: 服务器: from:https://www.cnblogs.com/aaa6818162/p/3862159.html
View Details安装适用于 Linux 的 Windows 子系统 在安装适用于 WSL 的任何 Linux 分发版之前，必须确保已启用“适用于 Linux 的 Windows 子系统”可选功能： 以管理员身份打开 PowerShell 并运行： PowerShell复制
|
1 2 |
<span class="hljs-pscommand">Enable-WindowsOptionalFeature</span><span class="hljs-parameter"> -Online</span><span class="hljs-parameter"> -FeatureName</span> <span class="hljs-pscommand">Microsoft-Windows</span>-<span class="hljs-pscommand">Subsystem-Linux</span> |
出现提示时，重启计算机。 安装所选的 Linux 分发版 若要下载并安装首选的分发版，可以选择三种做法： 从 Microsoft Store 下载并安装（参阅下文） 从命令行/脚本下载并安装（阅读手动安装说明） 下载并手动解压缩和安装（适用于 Windows Server – 参阅此处的说明） Windows 10 Fall Creators Update 和更高版本：从 Microsoft Store 安装 本部分适用于 Windows 内部版本 16215 或更高版本。 遵循以下步骤检查内部版本。 打开 Microsoft Store，并选择你偏好的 Linux 分发版。 单击以下链接会打开每个分发版的 Microsoft Store 页面： Ubuntu 16.04 LTS Ubuntu 18.04 LTS OpenSUSE Leap 15 OpenSUSE Leap 42 SUSE Linux Enterprise Server 12 SUSE Linux Enterprise Server 15 Kali Linux Debian GNU/Linux Fedora Remix for WSL Pengwin Pengwin […]
View DetailsWSL 的运行方式 可通过多种方式配合适用于 Linux 的 Windows 子系统运行 Linux。 [distro]，例如 ubuntu wsl.exe 或 bash.exe wsl [command] 或 bash -c [command] 要使用的方法取决于执行的操作。 按分发版启动 WSL 使用特定于分发版的应用程序运行某个分发版会在其自身的控制台窗口中将它启动。 这相当于在 Microsoft Store 中单击“启动”。 还可以在命令行中运行 [distribution].exe 来运行分发版。 以这种方式从命令行运行分发版的缺点是，会自动将工作目录从当前目录更改为分发版的主目录。 示例： console复制
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
PS C:\Users\sarah> pwd Path ---- C:\Users\sarah PS C:\Users\sarah> ubuntu scooley@scooley-elmer:~$ pwd /home/scooley scooley@scooley-elmer:~$ exit logout PS C:\Users\sarah> |
wsl 和 wsl [命令] 从命令行运行 WSL 的最佳方式是使用 wsl.exe。 示例： console复制
|
1 2 3 4 5 6 7 8 9 10 11 |
PS C:\Users\sarah> pwd Path ---- C:\Users\sarah PS C:\Users\sarah> wsl scooley@scooley-elmer:/mnt/c/Users/sarah$ pwd /mnt/c/Users/sarah |
这样，wsl 不仅可以保留当前工作目录，而且还允许结合 Windows 命令运行单个命令。 示例： console复制
|
1 2 3 4 5 6 7 8 9 10 11 12 13 |
PS C:\Users\sarah> Get-Date Sunday, March 11, 2018 7:54:05 PM PS C:\Users\sarah> wsl scooley@scooley-elmer:/mnt/c/Users/sarah$ date Sun Mar 11 19:56:57 DST 2018 scooley@scooley-elmer:/mnt/c/Users/sarah$ exit logout PS C:\Users\sarah> wsl date Sun Mar 11 19:55:47 DST 2018 |
示例： console复制
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
PS C:\Users\sarah> Get-VM Name State CPUUsage(%) MemoryAssigned(M) Uptime Status ---- ----- ----------- ----------------- ------ ------ Server17093 Off 0 0 00:00:00 Opera... Ubuntu Off 0 0 00:00:00 Opera... Ubuntu (bionic) Off 0 0 00:00:00 Opera... Windows Off 0 0 00:00:00 Opera... PS C:\Users\sarah> Get-VM | wsl grep "Ubuntu" Ubuntu Off 0 0 00:00:00 Opera... Ubuntu (bionic) Off 0 0 00:00:00 Opera... PS C:\Users\sarah> |
管理多个 Linux 分发版 Windows 10 版本 1903 和更高版本 可以使用 wsl.exe 管理适用于 Linux 的 Windows 子系统 (WSL) 中的分发版，包括列出可用分发版、设置默认分发版，以及卸载分发版。 每个 Linux 分发版独立管理自身的配置。 若要查看特定于分发版的命令，请运行 [distro.exe] /?。 例如 ubuntu /?。 列出分发版 wsl -l、wsl --list 列出可用于 WSL 的 Linux 分发版。 如果列出了某个分发版，表示该分发版已安装且可供使用。 wsl --list --all 列出所有分发版，包括当前不可用的分发版。 这些分发版可能正在安装、卸载或处于损坏状态。 wsl --list --running 列出当前正在运行的所有分发版。 设置默认分发版 默认 WSL 分布版是在命令行中运行 wsl 时运行的分发版。 wsl […]
View Details在多种情况下，你可能无法（或不想）通过 Microsoft Store 安装 WSL Linux 发行版。 具体而言，你可能运行的是不支持 Microsoft Store 或公司网络策略和/或管理员在你的环境中不允许 Microsoft Store 使用的 Windows Server 或长期服务（LTSC）桌面操作系统 SKU。 在这些情况下，虽然 WSL 本身可用，但如果你无法访问应用商店，如何下载并在 WSL 中安装 Linux 发行版？ 注意：不允许在 Windows 10 S 模式上运行命令行 shell 环境，包括 Cmd、PowerShell 和 Linux/WSL 发行版。 存在此限制是为了确保模式提供的完整性和安全性目标：阅读此文章了解详细信息。 下载发行版 如果 Microsoft Store 应用不可用，则可以通过单击以下链接下载并手动安装 Linux 发行版： Ubuntu 18.04 Ubuntu 18.04 ARM Ubuntu 16.04 Debian GNU/Linux Kali Linux OpenSUSE Leap 42 SUSE Linux Enterprise Server 12 Fedora Remix for WSL 这将导致 <distro>.appx 包下载到你选择的文件夹。 按照安装说明安装下载的发行版。 通过命令行下载发行版 如果愿意，也可以通过命令行下载首选的发行版： 使用 PowerShell 下载 若要使用 PowerShell 下载发行版，请使用WebRequest cmdlet。 下面是下载 Ubuntu 16.04 的示例说明。 PowerShell复制
|
1 2 |
<span class="hljs-pscommand">Invoke-WebRequest</span><span class="hljs-parameter"> -Uri</span> https://aka.ms/<span class="hljs-pscommand">wsl-ubuntu</span>-<span class="hljs-number">1604</span><span class="hljs-parameter"> -OutFile</span> Ubuntu.appx<span class="hljs-parameter"> -UseBasicParsing</span> |
提示 如果下载需要很长时间，请通过设置 $ProgressPreference = 'SilentlyContinue' 来关闭进度栏。 使用卷下载 Windows 10 春季2018更新（或更高版本）包含可从命令行调用 web […]
View Details