上篇博文：http://www.cnblogs.com/wolf-sun/p/3329558.html
介绍了客户端连接服务端，一对一，多对一的情况，下面实现服务器接收消息的功能。LZ这些弄的比较慢，也是边学习，边动手实现的。具体步骤在注释中写的比较清楚，不懂的可以留言，LZ会尽快回复。共同学习，共同进步。
接收消息时机
什么时候接收消息？当服务器开始监听，有客户端连接，并且连接成功，此时负责通信的Socket已经创建，此时就可以接收消息了，可以通过Socket的Receive()方法接收消息。
// 摘要:
// 从绑定的 System.Net.Sockets.Socket 套接字接收数据，将数据存入接收缓冲区。
//
// 参数:
// buffer:
// System.Byte 类型的数组，它是存储接收到的数据的位置。
//
// 返回结果:
// 接收到的字节数。
//
// 异常:
// System.ArgumentNullException:
// buffer 为 null。
//
// System.Net.Sockets.SocketException:
// 试图访问套接字时发生错误。 有关更多信息，请参见备注部分。
//
// System.ObjectDisposedException:
// System.Net.Sockets.Socket 已关闭。
//
// System.Security.SecurityException:
// 调用堆栈中的调用方没有所需的权限。
public int Receive(byte[] buffer);
上面代码介绍了Receive方法接收参数及返回值。
private void ListenConn(object o)
{
//将参数o 转化为监听的socket
Socket socketListener = o as Socket;
//写入循环 每一个连接就创建一个通信用的socket
while (true)
{
//当有客户端连接成功 创建通信用的socket
Socket connSocket = socketListener.Accept();
string ip = connSocket.RemoteEndPoint.ToString();
ShowMsg(ip + " " + DateTime.Now.ToString() + " 连接成功");
//创建一个新线程去接收消息
Thread th = new Thread(ReceiveMsg);
th.Start(connSocket); }
}
接收消息的代码：
//接收客户端的消息
private void ReceiveMsg(object o)
{
Socket connSocket = o as Socket; //通信用的socket连接成功 就可以接收消息了
byte[] buffer = new byte[ * * ];//5M缓存
while (true)
{
//count是当前接收的字节个数
int count = connSocket.Receive(buffer);
string ip = connSocket.RemoteEndPoint.ToString();
//判断接收到的字节个数 是0表示客户端关闭了
if (count > )
{ //将字节转换为字符串
string msg = Encoding.UTF8.GetString(buffer, , count);
ShowMsg(ip + " " + DateTime.Now.ToString() + "\r\n" + msg);
}
else
{
//socket没办法发送空消息 如果收到空消息 客户端关闭
ShowMsg(ip + ":" + "断开连接");
connSocket.Close();
break; } } }
测试：仍然用telnet命令来测试：telnet 127.0.0.1 50000
测试结果：多对一，一对一，发送消息正常，关闭客户端，服务端正常显示哪个客户端断开连接。
服务器端所有代码：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms; namespace Wolfy.ChatServer
{
public partial class Server : Form
{
public Server()
{
InitializeComponent();
//不让其检查跨线程的操作
Control.CheckForIllegalCrossThreadCalls = false;
}
//存放endpoin和通信用的socket
Dictionary<string, Socket> dic = new Dictionary<string, Socket>();
private void btnSend_Click(object sender, EventArgs e)
{
ServerSendMsg(this.txtInputMsg.Text);
}
/// <summary>
/// 服务器给客户端发送消息
/// </summary>
private void ServerSendMsg(string msg)
{
//服务器给客户端发消息
string userkey = comboBoxEndpoint.Text;
if (!string.IsNullOrEmpty(userkey))
{
ShowMsg(msg);
byte[] buffer = Encoding.UTF8.GetBytes(msg);
dic[userkey].Send(buffer);
msg = "";
}
else
{
MessageBox.Show("请选择客户端");
}
} private void btnStartService_Click(object sender, EventArgs e)
{
//服务器ip地址
IPAddress ip = IPAddress.Parse(txtIPAddress.Text);
//ip地址和端口
IPEndPoint endpoint = new IPEndPoint(ip, int.Parse(txtPort.Text));
//创建用于监听的socket
Socket socketListener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//绑定ip和端口
socketListener.Bind(endpoint);
//开始监听 限制连接数 最多可以连接10个
socketListener.Listen();
ShowMsg("开始监听......");
//创建线程 去监听连接
Thread th = new Thread(ListenConn);
//将线程变为后台线程
th.IsBackground = true;
th.Start(socketListener);
}
private void ListenConn(object o)
{
//将参数o 转化为监听的socket
Socket socketListener = o as Socket;
//写入循环 每一个连接就创建一个通信用的socket
while (true)
{
//当有客户端连接成功 创建通信用的socket
Socket connSocket = socketListener.Accept();
string ip = connSocket.RemoteEndPoint.ToString();
ShowMsg(ip + " " + DateTime.Now.ToString() + " 连接成功");
//连接成功后加入字典
dic.Add(ip, connSocket);
comboBoxEndpoint.Items.Add(ip);
//创建一个新线程去接收消息
Thread th = new Thread(ReceiveMsg);
th.Start(connSocket);
} }
//接收客户端的消息
private void ReceiveMsg(object o)
{
Socket connSocket = o as Socket; //通信用的socket连接成功 就可以接收消息了
byte[] buffer = new byte[ * * ];//5M缓存
while (true)
{
//count是当前接收的字节个数
int count = connSocket.Receive(buffer);
string ip = connSocket.RemoteEndPoint.ToString();
//判断接收到的字节个数 是0表示客户端关闭了
if (count > )
{
//将字节转换为字符串
string msg = Encoding.UTF8.GetString(buffer, , count);
ShowMsg(ip + " " + DateTime.Now.ToString() + "\r\n" + msg);
}
else
{
//socket没办法发送空消息 如果收到空消息 客户端关闭
ShowMsg(ip + ":" + "断开连接");
connSocket.Close();
break;
} } }
/// <summary>
/// 提示信息辅助方法
/// </summary>
/// <param name="msg"></param>
private void ShowMsg(string msg)
{
this.txtMsgView.AppendText(msg + "\r\n");
} private void txtInputMsg_KeyUp(object sender, KeyEventArgs e)
{
//如果用户按下了Enter键
if (e.KeyCode == Keys.Enter)
{
//则调用 服务器向客户端发送信息的方法
ServerSendMsg(this.txtInputMsg.Text);
}
}
}
}
客户端实现
客户端创建的socket即负责连接又负责通信，所以这里和服务端不同。客户端连接、接收消息和发送消息代码如下：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Net;
using System.Threading;
namespace Wolf.ChatClient
{
public partial class Client : Form
{
public Client()
{
InitializeComponent();
//不让检查跨线程操作
Control.CheckForIllegalCrossThreadCalls = false;
}
Socket socket;
private void btnStartService_Click(object sender, EventArgs e)
{
//连接服务器的ip和端口
IPAddress ip = IPAddress.Parse(txtIPAddress.Text);
IPEndPoint endpoint = new IPEndPoint(ip, int.Parse(txtPort.Text));
//客户端的socket即负责连接又负责通信
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//连接服务器
socket.Connect(endpoint);
ShowMsg("连接成功......");
//和服务器连接成功后就可以接收服务端的消息了
Thread th = new Thread(ReceiveMsg);
th.IsBackground = true;
th.Start(); }
private void ReceiveMsg()
{
byte[] buffer = new byte[ * * ];
while (true)
{
int count = socket.Receive(buffer);
string msg = Encoding.UTF8.GetString(buffer, , count);
ShowMsg(this.txtIPAddress.Text + ":" + this.txtPort.Text + " " + DateTime.Now.ToString() + "\r\n" + msg);
}
}
private void ShowMsg(string msg)
{
txtMsgView.AppendText(msg + "\r\n");
}
private void btnSend_Click(object sender, EventArgs e)
{
ClientSendMsg(this.txtInputMsg.Text);
} /// <summary>
/// 客户端向服务端发送消息
/// </summary>
/// <param name="msg"></param>
private void ClientSendMsg(string msg)
{
//向服务端发送消息
if (socket != null)
{
ShowMsg(msg);
byte[] buffer = Encoding.UTF8.GetBytes(msg);
socket.Send(buffer);
msg = "";
}
else
{
ShowMsg("<<<<请先连接服务器>>>");
}
} private void txtInputMsg_KeyUp(object sender, KeyEventArgs e)
{
//如果用户按下了Enter键
if (e.KeyCode == Keys.Enter)
{
//则调用 服务器向客户端发送信息的方法
ClientSendMsg(this.txtInputMsg.Text);
}
} private void Client_FormClosing(object sender, FormClosingEventArgs e)
{
//客户端关闭 关闭socket
socket.Shutdown(SocketShutdown.Both);
}
}
}
测试结果：
结语：
边学习，边动手，实现了两端通信，目前支持一对一，多对一通信功能，代码中针对关闭客户端的情况还有bug，有待进一步修改。
Socket网络编程（3）--两端通信的更多相关文章
-
socket 网络编程高速入门（一）教你编写基于UDP/TCP的服务（client）通信
由于UNIX和Win的socket大同小异,为了方便和大众化,这里先介绍Winsock编程. socket 网络编程的难点在入门的时候就是对基本函数的了解和使用,由于这些函数的结构往往比較复杂,參数大 ...
-
Python之路【第七篇】python基础 之socket网络编程
本篇文章大部分借鉴 http://www.cnblogs.com/nulige/p/6235531.html python socket 网络编程 一.服务端和客户端 BS架构 (腾讯通软件:ser ...
-
Socket网络编程-基础篇
Socket网络编程 网络通讯三要素: IP地址[主机名] 网络中设备的标识 本地回环地址:127.0.0.1 主机名:localhost 端口号 用于标识进程的逻辑地址 有效端口:0~65535 其 ...
-
循序渐进Socket网络编程（多客户端、信息共享、文件传输）
循序渐进Socket网络编程(多客户端.信息共享.文件传输) 前言:在最近一个即将结束的项目中使用到了Socket编程,用于调用另一系统进行处理并返回数据.故把Socket的基础知识总结梳理一遍. 1 ...
-
Py西游攻关之Socket网络编程
新闻 管理 Py西游攻关之Socket网络编程 知识预览 计算机网络 回到顶部 网络通信要素: A:IP地址 (1) 用来标识网络上一*立的主机 (2) IP地址 = 网络地址 + 主机 ...
-
Python面向对象进阶和socket网络编程-day08
写在前面 上课第八天,打卡: 为什么坚持?想一想当初: 一.面向对象进阶 - 1.反射补充 - 通过字符串去操作一个对象的属性,称之为反射: - 示例1: class Chinese: def __i ...
-
Socket网络编程TCP、UDP演示样例
Socket网络编程: 1) OSI(了解): 国际标准化组织ISO(International Orgnization for Standardization)指定了网络通信的模型:开放系统互联(O ...
-
Socket网络编程-TCP编程
Socket网络编程-TCP编程 作者:尹正杰 版权声明:原创作品,谢绝转载!否则将追究法律责任. 一.socket介绍 1>.TCP/IP协议 2>.跨网络的主机间通讯 在建立通信连接的 ...
-
Python面向对象进阶和socket网络编程
写在前面 为什么坚持?想一想当初: 一.面向对象进阶 - 1.反射补充 - 通过字符串去操作一个对象的属性,称之为反射: - 示例1: class Chinese: def __init__(self ...
-
Linux Socket 网络编程
Linux下的网络编程指的是socket套接字编程,入门比较简单.在学校里学过一些皮毛,平时就是自学玩,没有见识过真正的socket编程大程序,比较遗憾.总感觉每次看的时候都有收获,但是每次看完了之后 ...
随机推荐
-
js jquery 页面加载初始化方法
js jquery 页面加载初始化方法 一.js页面加载初始化方法 // 1.在body里面写初始化方法. <body onload='init()'> </body> < ...
-
CentOS最大文件描述符限制更改
系统级的限制:/proc/sys/fs/file-max中设定了系统最大能打开的文件数. 查看该值可以用如下方式: [root@#panda ~]# cat /proc/sys/fs/file-max ...
-
springmvc整合fastjson
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.sp ...
-
try-catch（C# 参考）
https://msdn.microsoft.com/zh-cn/library/0yd65esw.aspx Try-catch 语句包含一个后接一个或多个 catch 子句的 try 块,这些子句指 ...
-
Help Viewer 2.2 独立运行
"C:\Program Files (x86)\Microsoft Help Viewer\v2.2\HlpViewer.exe" /catalogName VisualStudi ...
-
强迫症和拖延症患者如何应对马桶4(遨游Maxthon)“上次未关闭页面”丢失的问题
强迫症和拖延症患者如何应对马桶4(遨游Maxthon)“上次未关闭页面”丢失的问题 用了马桶好多年,虽然一直bug不断,经常假死丢数据坑爹什么的,但是总得来说还是略有感情,不忍舍弃. 马桶一直有一个好 ...
-
TLD视觉跟踪算法（转）
源:TLD视觉跟踪算法 TLD算法好牛逼一个,这里有个视频,是作者展示算法的效果,http://www.56.com/u83/v_NTk3Mzc1NTI.html.下面这个csdn博客里有人做的相关总 ...
-
jQuery validata插件实现（每周一插件系列）
大家好,第一次写有点正规的博客,以前都是随手复制几下.为了打LOL,我写快点,代码我都复制在最下面了,并且写了大量的注释. 首先我写jquery插件,喜欢这么写(好处有很多,以后在讲,哈哈,看过jQu ...
-
Centos5搭建vsftpd服务
更换镜像源 由于centos5已经历史久远,内置的镜像源已经不能用.看: 因此,我手工更换了阿里云的源.(ps:我本来是想用网易的源,但不知为什么,这个源在安装vsftpd时提示http 404错误) ...
-
（转）Java中使用正则表达式的一个简单例子及常用正则分享
转自:http://www.jb51.net/article/67724.htm 这篇文章主要介绍了Java中使用正则表达式的一个简单例子及常用正则分享,本文用一个验证Email的例子讲解JAVA中如 ...