socket实现Windows Phone 7即时聊天

gaofeng0210

　　本例实现一个简单的控制台与wp7端的聊天对话。采用多线程处理接入的客户端。代码都贴上来吧。注释写的很明白了应该。传下图：

　　xaml文件：























　　wp7 cs:



using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Animation;
using System.Windows.Shapes;
using Microsoft.Phone.Controls;
using System.Net.Sockets;
using System.Threading;
using System.Text;
namespace WeiboSdkSample.PageViews
{
public partial class chat : PhoneApplicationPage
{
Socket s = null;
///
/// 枚举状态字
///
enum ClientStatus : byte
{
Connecting, Connected, Receiving, Received, Shutting, Shutted
}
///
/// clientStatus 表示当前连接状态
///
ClientStatus clientStatus = ClientStatus.Shutted;
static ManualResetEvent done = new ManualResetEvent(false);
public chat()
{
InitializeComponent();
bool retVal=EstablishTCPConnection("222.27.111.87", int.Parse("8888"));
}
///
/// 发送消息
///
///
///
private void buttonSend_Click(object sender, RoutedEventArgs e)
{
Send(textBoxTextToSend.Text);
}
///
/// 连接服务器
///
///
///
///
public bool EstablishTCPConnection(string host, int port)
{
s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();
socketEventArg.RemoteEndPoint = new DnsEndPoint(host, port);
socketEventArg.Completed += new EventHandler(delegate(object o, SocketAsyncEventArgs e)
{
if (e.SocketError != SocketError.Success)
{
if (e.SocketError == SocketError.ConnectionAborted)
{
Dispatcher.BeginInvoke(() => MessageBox.Show("连接超时请重试！ " + e.SocketError));
}
else if (e.SocketError == SocketError.ConnectionRefused)
{
Dispatcher.BeginInvoke(() => MessageBox.Show("服务器端问启动" + e.SocketError));
}
else
{
Dispatcher.BeginInvoke(() => MessageBox.Show("出错了" + e.SocketError));
}
}
else
{
//连接成功 开启一个线程循环接收消息
Thread th = new Thread(new ThreadStart(Receive));
th.Start();
//添加服务器到在线列表
Dispatcher.BeginInvoke(() => onlinelist.Items.Add("  小i"));
}
done.Set();
});
done.Reset();
s.ConnectAsync(socketEventArg);
clientStatus = ClientStatus.Connecting;
return done.WaitOne(10000);
}
///
/// 发送消息
///
///
///
public bool Send(string data)
{
if (s != null)
{
SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();
socketEventArg.RemoteEndPoint = s.RemoteEndPoint;
socketEventArg.UserToken = null;
socketEventArg.Completed += new EventHandler(delegate(object o, SocketAsyncEventArgs e)
{
done.Set();
});
socketEventArg.SetBuffer(Encoding.UTF8.GetBytes(data), 0, Encoding.UTF8.GetBytes(data).Length);
done.Reset();
s.SendAsync(socketEventArg);
chatlistbox.Items.Add(" 我：" + data);
return done.WaitOne(10000);
}
return false;
}
///
/// 循环接收消息
///
public void Receive()
{
string received = "";
var socketReceiveArgs = new SocketAsyncEventArgs();
while (clientStatus != ClientStatus.Shutted)
{
switch (clientStatus)
{
case ClientStatus.Connecting:
{
socketReceiveArgs.SetBuffer(new byte[512], 0, 512);
socketReceiveArgs.Completed += delegate(object sender1, SocketAsyncEventArgs receiveArgs)
{
if (receiveArgs.SocketError == SocketError.Success)
{
if (clientStatus != ClientStatus.Shutting)
{
if (receiveArgs.BytesTransferred == 0)
clientStatus = ClientStatus.Shutting;
else
{
clientStatus = ClientStatus.Received;
received = Encoding.UTF8.GetString(receiveArgs.Buffer, receiveArgs.Offset, receiveArgs.BytesTransferred);
// MessageBox.Show(received);
Dispatcher.BeginInvoke(() => chatlistbox.Items.Add(" 小i：" + received));

}
}
}
else
clientStatus = ClientStatus.Shutting;
};
clientStatus = ClientStatus.Receiving;
s.ReceiveAsync(socketReceiveArgs);
break;
}
case ClientStatus.Received:
{
clientStatus = ClientStatus.Receiving;
s.ReceiveAsync(socketReceiveArgs);
break;
}
case ClientStatus.Shutting:
{
s.Close();
clientStatus = ClientStatus.Shutted;
break;
}
}
}
}
public void CloseSocket()
{
if (s != null)
{
s.Close();
}
}
///
/// 这个listbox在线列表是项目需要加加上来的，你们删掉吧。。
///
///
///
private void onlinelist_SelectionChanged(object sender, SelectionChangedEventArgs e)
{
onlinelist.Visibility = Visibility.Collapsed;
}
private void button1_Click(object sender, RoutedEventArgs e)
{
onlinelist.Visibility = onlinelist.Visibility == Visibility.Visible ? Visibility.Collapsed : Visibility.Visible;
}
}
}
　　控制台：



using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
namespace ConsoleApplication1
{
class Program
{
static Socket clientSocket=null;
Socket serverSocket = null;
static void Main(string[] args)
{
Console.WriteLine("----------------------windows phone7 socket server------------------------");
IPEndPoint id = new IPEndPoint(IPAddress.Parse("222.27.111.87"), 8888);
Console.WriteLine("local address:"+id.Address+"Port:"+id.Port);
Console.WriteLine("---input message and press enter to send your message to all client--- ");
Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
serverSocket.Bind(id);
serverSocket.Listen(10);
while (true)
{
try
{
//在套接字上接收接入的连接
clientSocket = serverSocket.Accept();
//开一个线程处理
Thread clientThread = new Thread(new ThreadStart(ReceiveData));
clientThread.Start();
}
catch (Exception ex)
{
}
}
}
private static void ReceiveData()
{
//状态
bool keepalive = true;
Socket s = clientSocket;
Byte[] buffer = new Byte[1024];
//根据收听到的客户端套接字向客户端发送信息
IPEndPoint clientep = (IPEndPoint)s.RemoteEndPoint;
Console.WriteLine("Client：" + clientep.Address + "("+clientep.Port+")"+"上线了");
string welcome = "欢迎使用XXX，您已登录成功";
byte[] data = new byte[1024];
data = Encoding.UTF8.GetBytes(welcome);
s.Send(data, data.Length, SocketFlags.None);
//开启新线程处理用户输入 换行后发送消息
Thread clientThread = new Thread(new ThreadStart(delegate (){
while (keepalive)
{
var newMessage = Console.KeyAvailable ? Console.ReadLine() : null;
if (newMessage != null)
{
data = Encoding.UTF8.GetBytes(newMessage);
s.Send(data, data.Length, SocketFlags.None);
}
}
})); clientThread.Start();
while (keepalive)
{
//在套接字上接收客户端发送的信息
int bufLen = 0;
try
{
bufLen = s.Available;
s.Receive(buffer, 0, bufLen, SocketFlags.None);
if (bufLen == 0)
continue;
}
catch (Exception ex)
{
Console.WriteLine("Client：" + clientep.Address + "(" + clientep.Port + ")" + "下线了");
keepalive = false;
return;
}
clientep = (IPEndPoint)s.RemoteEndPoint;
string clientcommand = System.Text.Encoding.ASCII.GetString(buffer).Substring(0, bufLen);
Console.WriteLine("wp7:"+clientcommand);
}
}
}
}
　　仓促作品，不善之处 ，望请指教
　　本博客地址http://www.iyunv.com/shit