[求助] 求一个c/s模式并采用异步Socket的 某管理系统代码

我想要的是一个用C#开发的win窗体c/s模式的程序，并不是asp.net的网页程序。

最好是用vs.net2005编辑 数据库是sql sever 2000

系统可以为：学生成绩管理系统  某公司人员管理系统  药房药品管理系统  等等类似的

模式基本是：客户端---(互联网络路径)---服务器---数据库

服务器端：接受用户发送过来的信息，并进行与数据库相关的处理。如当用户发送登录、注册或进行别的请求时，服务器或做出相应的处理，并把处理后的信息返回给客户端。

客户端：与服务器建立连接，用户登录后能进行一系列的操作。如查询、添加、删除等基本操作。


本人是初学者，只做过小的聊天系统，对多个数据的同时发送很不了解。现在想开发个c/s模式下的程序，但由于对客户端与服务器间的多个数据的交互很不了解，所以希望大家能发个代码让我学习。

我一直认为每个人都是从新手过来的，每个人都需要帮助，每个热爱学习的人都应该得到大家的支持，对每个支持我的人，我都会非常感谢.....

我的邮箱是：[e-mail]

31 个解决方案

#1

友情支持

#2

呵呵，感谢  折翅的天使 支持....

上帝 和 观音 都会保佑你的.....呵呵....

#3

直接要源代码~~~这个比较困难，希望你能遇到好心人，呵呵

#4

呵呵，感谢  骗子不可怕，就怕骗子有文化！ 支持.....

如来   和  耶稣   都会保佑你的.....呵呵....

我本来也不想要的啊....但这也不是一两句话就能说出来的，如果有人不怕麻烦，愿意把关键的代码贴出来，和说明关键的思路，那我更是感激啊....

整个代码无所谓就是重复，重复，在重复....

就像知道了怎样向服务器 发送 用户名和密码，并能够登录，那你还不知道怎么写注册吗？注册时发送的那些性别、年龄之类的，和向服务器发送 用户名和密码 不是一个道理吗？

如果了解了：服务器是如何接收 并区分 客户端发送来的就是用户名和密码，并有相应的处理：查询数据库，验证是否有该用户。

难道还不会写：服务器是如何接收 并区分 客户端发送来的是注册请求(里面包括性别、年龄...)，并有相应的处理：在数据库的某表中添加该用户...

很多时候我只需要一些开阔的思路，正确的写法....

当然还是那句话，我是新手，我不可能创造写法，我需要老手的指导和带动.....

我想这也是每个老手在新手期同样希望的....

#5

为什么不做成
客户端+数据库的啊？
那样就不需要SOCKET编程了，比较方便。

#6

呵呵，感谢   笨熊   支持..... 

王母  和  财神       都会保佑你的.....呵呵.... 

单机版的我会啊，我在学着做个c/s模式的....不是为了完成任务。

#7

客户端---(互联网络路径)---服务器---数据库
------------------------
我现在在弄的和你这差不多
不过我的服务器在内网
想达到的目的是
内网的这台服务器一启动
客户端只要能上网都能够访问得到服务器
而这台服务器没有固定的IP
难办呀.............
一起求救吧.
支持.

#8

呵呵，感谢  我知道错了，以后我会及时结贴。 支持.....   

土地  和 月老    都会保佑你的.....呵呵....   



服务器可以启动时获取本地的ip...

这个怎么写...呵呵，估计又得搜 ...

这个周末一定要搞出来...不能拖了....

#9

呵呵，经过昨天下午到现在的努力...写了个关于客户端登录服务器的小程序，但貌似错误多多...

大家帮忙看看：

1：运行服务器，点击button1开始监听，然后并不运行客户端，直接点button2关闭服务器。
错误行：handler = listener.EndAccept(ar);  
报错为：无法访问已释放的对象。\r\n对象名:“System.Net.Sockets.Socket”。

2：运行服务器，点击button1开始监听，运行客户端，但马上报错：
错误行：int bytesRead = handler.EndReceive(ar);
报错为：由于线程退出或应用程序请求，已放弃 I/O 操作。

我第一次写c/s模式下的代码，罗嗦，幼稚，不简练，不优美的地方请大家指出：非常感谢！！！

服务器代码：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Data.SqlClient;
using System.Threading;

namespace fwq
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        StateObject state;
        private IPAddress myip = IPAddress.Parse("127.0.0.1");
        private IPEndPoint myserver;
        private Socket mySocket;
        private Socket handler;
        private string getCommand = "";
        private string[] spliComm;
        private bool Exists = false;
        private static AutoResetEvent myReset = new AutoResetEvent(false);
        private SqlCommand myselectcmd1;
        private SqlCommand myinsertcmd1;
        private SqlCommand mydeletecmd1;
        private SqlCommand myupdatecmd1;
        private SqlDataAdapter myda;
        private SqlConnection mycn;

        private void Form1_Load(object sender, EventArgs e)
        {
            System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false;
        }

        private void button1_Click(object sender, EventArgs e)
        {
            button1.Enabled = false;
            try
            {
                myserver = new IPEndPoint(myip, 5555);
                mySocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                mySocket.Bind(myserver);
                mySocket.Listen(50);
                Thread thread = new Thread(new ThreadStart(target));
                thread.Start();
            }
            catch (Exception ee) { MessageBox.Show(ee.Message + "\r\n"); }
        }
        private void target()
        {
            while (true)
            {
                myReset.Set();
                mySocket.BeginAccept(new AsyncCallback(AcceptCallback), mySocket);
                myReset.WaitOne();
            }
        }
        private void AcceptCallback(IAsyncResult ar)
        {
            myReset.Set();
            Socket listener = (Socket)ar.AsyncState;
            handler = listener.EndAccept(ar);   //报错：无法访问已释放的对象。\r\n对象名:“System.Net.Sockets.Socket”。
            getCommand = "";
            StateObject state = new StateObject();
            state.workSocket = handler;
            Thread thread = new Thread(new ThreadStart(begReceive));
            thread.Start();
        }
        private void begReceive()
        {
            StateObject state = new StateObject();
            state.workSocket = handler;
            handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReadCallback), state);
        }
        private void sendMessage(string message)
        {
            byte[] byteDate = System.Text.Encoding.UTF8.GetBytes(message + "\r\n");
            handler.BeginSend(byteDate, 0, byteDate.Length, 0, new AsyncCallback(SendCallback), handler);
        }
        private void SendCallback(IAsyncResult ar)
        {
            try
            {
                handler = (Socket)ar.AsyncState;
                int bytesSent = handler.EndSend(ar);
            }
            catch (Exception ee)
            {
                MessageBox.Show(ee.Message);
            }
        }

        private string chenEnd(string aimString)
        {
            int x = aimString.IndexOf("\r\n");
            if (x != 1)
            {
                string subComm = aimString.Substring(0, x);
                getCommand = getCommand + subComm;
                return getCommand;
            }
            else
            {
                getCommand = getCommand + aimString;
                return "";
            }
        }
        private void spliCommand(string aimCommand)
        {
            char[] a = new char[] { };
            spliComm = new string[5];
            spliComm = aimCommand.Split(a);
        }
        private void ReadCallback(IAsyncResult ar)
        {
            StateObject state = (StateObject)ar.AsyncState;
            Socket tt = state.workSocket;
            int bytesRead = handler.EndReceive(ar); //报错：由于线程退出或应用程序请求，已放弃 I/O 操作。
            state.sb.Append(System.Text.Encoding.UTF8.GetString(state.buffer, 0, bytesRead));
            string content = state.sb.ToString();
            state.sb.Remove(0,content.Length);
            string command = chenEnd(content);
            getCommand = "";
            if (command != "")
            {
                spliCommand(command);
               
                string strSql1 = "select * from newuser";
                mycn = new SqlConnection();
                mycn = new SqlConnection("server=localhost;uid=sa;pwd=;database=openjjsys;");
                mycn.Open();
                myselectcmd1 = new SqlCommand(strSql1, mycn);
                SqlDataReader reader1 = myselectcmd1.ExecuteReader();

                Exists=false;
                while (reader1.Read())
                {
                    if (spliComm[0] == "1000")
                    {

                        int x = reader1.GetString(1).ToString().IndexOf(spliComm[1]);
                        int y = reader1.GetString(2).ToString().IndexOf(spliComm[2]);
                        if ((x != -1) && (y != -1))
                        {
                            sendMessage("1000" + "\r\n" + "1" + "\r\n" + "<EOF>");
                            Exists = true;
                        }
                        else
                        {
                            sendMessage("1000" + "\r\n" + "2" + "\r\n" + "<EOF>");
                        }
                    }
                }
                reader1.Close();
                mycn.Close();
            }
            tt.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReadCallback), state);
        }

        private void button2_Click(object sender, EventArgs e)
        {
	        button1.Enabled = true;
            try
            {
                mySocket.Close();
            }
            catch { MessageBox.Show("监听尚未开始，关闭无效！"); }
        }
    }
    public class StateObject
    {
        public Socket workSocket = null;
        public const int BufferSize = 1024;
        public byte[] buffer = new byte[BufferSize];
        public StringBuilder sb = new StringBuilder();
        public StateObject()
        { }
    }
}

#10

这是我的客户端

登录窗体的代码：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Net.Sockets;
using System.Net;
using System.Threading;
using System.Text;
using System.Windows.Forms;

namespace openjjkh
{
    public partial class enter : Form
    {
        public enter()
        {
            InitializeComponent();
        }

        private StateObject state;
        private IPAddress myip = IPAddress.Parse("127.0.0.1");
        private string getData = "";
        private string getCommand = "";
        private string[] spliComm;
        private IPEndPoint myserver;
        private Socket mySocket;
        private static ManualResetEvent connectReset = new ManualResetEvent(false);
        private static ManualResetEvent sendReset = new ManualResetEvent(false);

        private void enter_Load(object sender, EventArgs e)
        {
            System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false;
            try
            {
                myserver = new IPEndPoint(myip, 5555);
                mySocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                mySocket.BeginConnect(myserver, new AsyncCallback(ConnectCallback), mySocket);
                connectReset.WaitOne();
            }
            catch (Exception ee) { MessageBox.Show(ee.Message); }
        }
        private void button1_Click(object sender, EventArgs e)
        {
            string sendSele = null;
            if (textBox1.Text != "" && textBox2.Text != "")
            {
                sendSele = "1000" + " " + textBox1.Text + " " + textBox2.Text + "\r\n";
            }
            else
                MessageBox.Show("用户名或密码不能为空！");
        }
        private void ConnectCallback(IAsyncResult ar)
        {
            try
            {
                Socket client = (Socket)ar.AsyncState;
                client.EndConnect(ar);
                getData = "";
                
                Thread thread = new Thread(new ThreadStart(target));
                thread.Start();
                connectReset.Set();
            }
            catch { }
        }

        private void spliCommand(string aimCommand)
        {
            char[] a = new char[] { };
            spliComm = new string[5];
            spliComm = aimCommand.Split(a);
        }

        public void ReceiveCallback(IAsyncResult ar)
        {
            try
            {
                StateObject state = (StateObject)ar.AsyncState;
                Socket client = state.workSocket;
                int bytesRead = client.EndReceive(ar);
                state.sb.Append(System.Text.Encoding.UTF8.GetString(state.buffer, 0, bytesRead));
                string backString = state.sb.ToString();
                state.sb.Remove(0, backString.Length);
                string feedback = chenEnd(backString);
                getCommand = "";
                if (feedback != "")
                {
                    if (spliComm[0] == "1000")
                    {
                        if (spliComm[1] == "1")
                        {
                            khdwindow khwin = new khdwindow();
                            khwin.Show();
                            this.Hide();
                        }
                        else
                        {
                            MessageBox.Show("用户名或密码输入错误！！！");
                            textBox1.Text = "";
                            textBox2.Text = "";
                        }
                    }
                    getData = "";
                }
                client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
            }
            catch { }
        }


        private string chenEnd(string aimString)
        {
            int x = aimString.IndexOf("<EOF>");
            if (x != -1)
            {
                string subcomm = aimString.Substring(0, x);
                getData = getData + subcomm;
                return getData;
            }
            else
            {
                getData = getData + aimString;
                return "";
            }
        }

        private void SendCallback(IAsyncResult ar)
        {
            try
            {
                Socket client = (Socket)ar.AsyncState;
                sendReset.Set();
            }
            catch (Exception ee)
            {
                Console.WriteLine(ee.ToString());
            }
        }

        private void target()
        {
            try
            {
                StateObject state = new StateObject();
                state.workSocket = mySocket;
                mySocket.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);
            }
            catch (Exception ee)
            {
                MessageBox.Show(ee.Message);
            }
        }

    }
    public class StateObject
    {
        public Socket workSocket = null;
        public const int BufferSize = 1024;
        public byte[] buffer = new byte[BufferSize];
        public StringBuilder sb = new StringBuilder();
        public StateObject()
        { }
    }
}

肯定有很多问题的地方，请大家帮我指出....

非常感谢了....

#11

高手们帮我看看啊....

#12

最大的问题我看还是逻辑太乱

#13

呵呵，感谢  狗狗  支持.....   

西施  和  貂蝉  都会保佑你的.....呵呵....  


确实啊，我没写过这样的程序，这是第一次写，肯定有很多写的莫名其妙，让人感到好笑的地方 ....

这就是不成熟啊，所以我现在需要大家的帮助....

大家多给我指示，如果能很好的完成在客户端登录这个功能，我就能类比出注册等别的功能了...

大家都是中国人啊，要团结互助啊！！！

#14

友情支持

#15

友情支持

#16

呵呵，感谢 谢雨枫 支持.....       
杨玉环 和 王昭君  都会保佑你的.....呵呵....     

#17

哪个高手给我提点几句啥 ....

#18

求一个c/s模式并采用异步Socket的 某管理系统代码  
---------------------
做成客户端+数据库应该容易很多

#19

呵呵，感谢  忍者 支持.....               
关公 和  张飞   都会保佑你的.....呵呵....   

客户端+数据库的我会啊....        

#20

等我做出来了再给你吧

#21

呵呵，感谢 一个爱吃臭豆腐的坏男人 支持.....                               
炎帝 和  黄帝  都会保佑你的.....呵呵.... 

能帮我看看我上面写的代码，指点错误方面，和不足之处吗...？？      

#22

希望哪位大侠帮我看看啊....

把握代码中的不足能具体点指出 ...感激不尽啊 ...

#23

像这样的业务系统个人建议不要用Socket来开发，你可以使用.NET Remoting来开发。

#24

JF

#25

呵呵，感谢  牧野（高分亮解）支持....                                                             
主 和  神   都会保佑你的.....呵呵....  

我也明白，但现在偶很想用Socket去实现他...

------------------------------------ 

呵呵，感谢 云中看海 支持....                                                             
佛 和 党  都会保佑你的.....呵呵....

我也想加分啊...可我不够加的啊......  

#26

 *会保佑你的！

为什么不作成 Remoting，wcf，webservice的呢？不明白怎么想的！

#27

呵呵,老大,这种程序最好不要用Socket写,原因如下:
一是Socket编程复杂,一般是在局域网环境下做,安全设置比较高,因为要开端口
二是需要考虑防火墙的支持,就是没有防火墙,也要考虑服务商的支持,比如在辽宁,SQL SERVER的1433就是封的
三是要考虑代理服务器,如果客户端是公司,需公司是通过代理服务器上网呢,还要考虑代理服务器的支持
四是要有自己的传输协议

所以综上,如果要实现外网通信,最好还是用webServices,安全,简单

#28

呵呵，感谢 白雪公猪 支持...                                                 
老毛 和  小平  都会保佑你的.....呵呵....     

不是为了做一个东西，而是为了学一个东西.......

--------------------------------------------------

呵呵，感谢 大盗阿飞 支持...                                                 
三藏 和  阎王  都会保佑你的.....呵呵....   

做个大东西很复杂，但我要做的却是个小东西......虽然麻烦了点，但我还是想了解它.  

#29

该回复于2008-02-01 09:30:27被版主删除

#30

http://download.csdn.net/source/335689

#31

我也想知道。。。