简单的点对点聊天软件

在两台电脑上同时运行本程序，可以实现点对点的聊天。

输入对方IP，连接即可聊天。

源代码：

类ClassListener，监听通信信息。

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Net;

using System.Threading;

using System.Net.Sockets;

using System.Windows.Forms;

namespace PToP

{

public class AddMessageEventArge : EventArgs

{

public string mess; //定义一个全局变量

}

class ClassListener

{

private Thread th;

private TcpListener tcp1;

public bool listenerRun = true;

public event EventHandler<AddMessageEventArge> OnAddMessage;

//启动线程开始监听

public void StartListen()

{

th = new Thread(new ThreadStart(Listen));

th.Start();

}

//停止监听

public void stop()

{

tcp1.Stop();

th.Abort();

}

public void Listen()

{

try

{

IPAddress addr = new IPAddress(Dns.GetHostByName(Dns.GetHostName()).AddressList[0].Address);

IPEndPoint iplocalendpoint = new IPEndPoint(addr, 5656);

tcp1 = new TcpListener(iplocalendpoint);

tcp1.Start();

while (listenerRun)

{

Socket s = tcp1.AcceptSocket();

string remote = s.RemoteEndPoint.ToString();

Byte[] stream = new Byte[512];

int i = s.Receive(stream);

string msg = "<" + remote + ">" + System.Text.Encoding.UTF8.GetString(stream);

AddMessageEventArge arg = new AddMessageEventArge();

arg.mess = msg;

OnAddMessage(this, arg);

}

}

catch(Exception ex)

{

MessageBox.Show(ex.ToString());

}

}

}

}

类ClassSender,实现发送聊天信息

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Net.Sockets;

using System.Net;

using System.Threading;

using System.Windows.Forms;

namespace PToP

{

class ClassSender

{

private string obj;

public ClassSender(string str)

{

obj=str;

}

public void Send(string str)

{

try

{

TcpClient tcpc = new TcpClient(obj, 5656);

NetworkStream tcpstream = tcpc.GetStream();

Byte[] data = System.Text.Encoding.ASCII.GetBytes(str);

tcpstream.Write(data, 0, data.Length);

tcpstream.Close();

tcpc.Close();

}

catch(Exception)

{

MessageBox.Show("连接被目标主机拒绝!");

}

}

}

}

窗体代码中，添加连接目标计算机和发送聊天信息的程序

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.Net.Security;

namespace PToP

{

public partial class Form1 : Form

{

//定义委托

public delegate void InvokeDelegate();

public bool appRun = true;

private ClassListener Lie;

private ClassSender sen;

string Strs = "";

public Form1()

{

InitializeComponent();

}

private void button3_Click(object sender, EventArgs e)

{

Application.Exit();

}

private void Form1_Load(object sender, EventArgs e)

{

}

//接收事件

void Lie_OnAddMessage(object sender, AddMessageEventArge e)

{

Strs = e.mess.ToString();

Invoke_Click(null, null);

}

//委托

private void Invoke_Click(object sender, EventArgs e)

{

textBox1.BeginInvoke(new InvokeDelegate(InvokeMethod));

}

public void InvokeMethod()

{

if (textBox1.Text == "")

{

textBox1.Text = Strs;

}

else

{

textBox1.Text = textBox1.Text + "/r/n" + Strs;

}

}

//连接目标计算机

private void button1_Click(object sender, EventArgs e)

{

try

{

//连接

Lie.listenerRun = false;

Lie.stop();

}

catch (NullReferenceException) { ;}

finally

{

Lie = new ClassListener();

Lie.OnAddMessage +=new EventHandler<AddMessageEventArge>(Lie_OnAddMessage);

Lie.StartListen();

}

}

//发送聊天记录信息

private void button2_Click(object sender, EventArgs e)

{

if (textBox3.Text == "")

{

MessageBox.Show("请输入目标主机的IP地址");

}

else if (textBox2.Text == "")

{

MessageBox.Show("不能发送空信息!");

}

else

{

IPAddress ipaddress = new System.Net.IPAddress(Dns.GetHostByName(Dns.GetHostName()).AddressList[0].Address);

if (textBox1.Text == "")

{

textBox1.Text = "<" + ipaddress.ToString() + "> " + textBox2.Text;

}

else

{

textBox1.Text =textBox1.Text +"/r/n"+ "<" + ipaddress.ToString() + "> " + textBox2.Text;

}

sen = new ClassSender(textBox3.Text);

sen.Send(textBox2.Text);

}

}

}

}