简单的点对点聊天软件

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

输入对方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);
}
}

}
}