asp.net利用socket实现简单多对多聊天室源码

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;

using System.Net;
using System.Net.Sockets;

using System.Threading;
using System.IO;

using System.Runtime.Serialization.Formatters.Binary;
namespace MyChatClient
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
Control.CheckForIllegalCrossThreadCalls = false;
}
Socket socket;
private void btnStart_Click(object sender, EventArgs e)
{
//服务器的ip地址与端口
IPAddress ip = IPAddress.Parse(txtServer.Text);
IPEndPoint point = new IPEndPoint(ip,int.Parse(txtPort.Text));
socket = new Socket( AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
//连接服务器
socket.Connect(point);
ShowMsg("连接成功");

//接收服务器发送的消息
Thread th = new Thread(RecMsg);
th.IsBackground = true;
th.Start();
}
catch (Exception ex)
{
ShowMsg(ex.Message);
}
}
//接收服务器发送过来的消息
void RecMsg()
{
while (true)
{
try
{
byte[] buffer = new byte[1024 * 1024];
int num = socket.Receive(buffer);

Common.MyCommon my = Deserialize(buffer, num);

//当是文字
if(my.Flag == 0)
{
string s = Encoding.UTF8.GetString(my.Buffer, 0,my.Buffer.Length);
ShowMsg(s);
}
//接收文件
else if (my.Flag == 1)
{
//提示是否保存文件
DialogResult dr = MessageBox.Show("是否保存文件？","提示",MessageBoxButtons.YesNo);
if (dr == System.Windows.Forms.DialogResult.Yes)
{
SaveFileDialog sfd = new SaveFileDialog();
//保存文件 win7下使用的时候注意，必须加this
if (sfd.ShowDialog(this) == System.Windows.Forms.DialogResult.OK)
{
using (FileStream fs = new FileStream(sfd.FileName,FileMode.Create))
{
fs.Write(my.Buffer,0,my.Buffer.Length);
}
}
}
}
else if (my.Flag == 2)
{
//窗口置于顶层
this.TopMost = true;
//震动
ZD();
}
}
catch (Exception ex)
{
ShowMsg(ex.Message);
break;
}
}
}

void ShowMsg(string msg)
{
txtLog.AppendText(msg + "rn");
}

//发送消息
private void btnSend_Click(object sender, EventArgs e)
{
if (socket != null)
{
try
{
byte[] buffer = Encoding.UTF8.GetBytes(txtMsg.Text);
socket.Send(buffer);
}
catch (Exception ex)
{
ShowMsg(ex.Message);
}
}
}

private void Form1_Load(object sender, EventArgs e)
{

}
//震动
string dir = "top";
int count = 10;
void ZD()
{
for (int i = 0; i {
if (dir == "top")
{
dir = "bottom";
this.Location = new Point(this.Location.X - 5, this.Location.Y - 5);
}
else
{
dir = "top";
this.Location = new Point(this.Location.X + 5, this.Location.Y + 5);
}
System.Threading.Thread.Sleep(50);
}

}

//反序列化，把一个字节数组转换成一个对象,
Common.MyCommon Deserialize(byte[] buffer,int num)
{
using (MemoryStream ms = new MemoryStream(buffer, 0, num))
{
BinaryFormatter bf = new BinaryFormatter();
Common.MyCommon my = bf.Deserialize(ms) as Common.MyCommon;

return my;
}
}
}
}