首页 新闻 论坛 群组 Blog 文档 下载 读书 Tag 网摘 搜索 .NET Java 游戏 视频 人才 外包 培训 数据库 书店 程序员
中国软件网
欢迎您:游客 | 登录 注册 帮助
  • 关于socket与线程的一点问题 [已结贴,结贴人:calum]
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 15:19:43 楼主
    开发平台VS2005,开发语言C#

    我正在学socket的使用,服务器监听客户端那方面的,但是我现在只能写出,一个服务器监听一个客户端,代码(为控制台应用程序)如下:

    服务器端:
    using System;
    using System.Collections.Generic;
    using System.Text;
    using System.Net;
    using System.Net.Sockets;

    namespace server
    {
        class Program
        {
            static void Main(string[] args)
            {
                int port = 2000;
                string host = "192.168.1.3";

            /**////创建终结点(EndPoint)
                IPAddress ip  = IPAddress.Parse(host);//把ip地址字符串转换为IPAddress类型的实例
                IPEndPoint ipe = new IPEndPoint(ip, port);//用指定的端口和ip初始化IPEndPoint类的新实例

            /**////创建socket并开始监听
                Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建一个socket对像,如果用udp协议,则要用SocketType.Dgram类型的套接字
                s.Bind(ipe);//绑定EndPoint对像(2000端口和ip地址)
                s.Listen(0);//开始监听
                Console.WriteLine("等待客户端连接");

            /**////接收到client连接,为此连接建立新的socket,并接受信息
                Socket temp = s.Accept();//为新建连接创建新的socket
                Console.WriteLine("建立连接");
                string recvStr = "";
                byte[] recvBytes = new byte[1024];
                int bytes;
                bytes = temp.Receive(recvBytes, recvBytes.Length, 0);//从客户端接受信息
                recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);//获取字符串(字节数组,索引,字节数)

            /**////给client端返回信息
                Console.WriteLine("接收来自客户端的信息:{0}", recvStr);//把客户端传来的信息显示出来
                string sendStr = "ok!Client send message successful!";
                byte[] bs = Encoding.ASCII.GetBytes(sendStr);
                temp.Send(bs, bs.Length, 0);//返回信息给客户端
                temp.Close();
                s.Close();
                Console.ReadLine();
            }
        }
    }

    客户端:
    using System;
    using System.Collections.Generic;
    using System.Text;
    using System.Net;
    using System.Net.Sockets;

    namespace Client
    {
        class Program
        {
            static void Main(string[] args)
            {
                try
                {
                    int port = 2000;
                    string host = "192.168.1.3";
                    /**/
                    ///创建终结点EndPoint
                    IPAddress ip = IPAddress.Parse(host);
                    //IPAddress ipp = new IPAddress("127.0.0.1");
                    IPEndPoint ipe = new IPEndPoint(ip, port);//把ip和端口转化为IPEndpoint实例


                    for (int i = 0; i <= 2; i++)
                    {
                        /**////创建socket并连接到服务器
                        Socket c = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建Socket
                        Console.WriteLine("连接服务器...");
                        c.Connect(ipe);//连接到服务器


                        /**/
                        ///向服务器发送信息             
                        Console.WriteLine("发送信息...");
                        string sendStr = "hello!This is a socket test";
                        byte[] bs = Encoding.ASCII.GetBytes(sendStr);//把字符串编码为字节
                        c.Send(bs, bs.Length, 0);//发送信息

                        /**/
                        ///接收从服务器返回的信息
                        string recvStr = "";
                        byte[] recvBytes = new byte[1024];
                        int bytes;
                        bytes = c.Receive(recvBytes, recvBytes.Length, 0);//从服务器端接受返回信息
                        recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);
                        Console.WriteLine("接收来自服务器的信息:{0}", recvStr);//显示服务器返回信息
                        /**/
                        ///一定记着用完socket后要关闭
                        c.Close();
                    }
                }
                catch (ArgumentNullException e)
                {
                    Console.WriteLine("argumentNullException: {0}", e);
                }
                catch (SocketException e)
                {
                    Console.WriteLine("SocketException:{0}", e);
                }

                Console.WriteLine("Press Enter to Exit");
                Console.ReadLine();
            }
        }
    }

    我想知道怎样让服务器监听多个客户端,希望大伙知道的告诉我一下,windows应用程序或者控制台应用程序都行,能给个这方面的网址什么的也行,要好的,我在网上也搜了一些,但是基本上是不能运行的,老错误...
    60  修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 15:25:381楼 得分:0
    SF帮顶
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 15:26:132楼 得分:15
    做Socket一定要使用多线程
    一个线程侦听,然后为每个客户分别建立一个连接,如果多客户端使用异步。
    要例子的话你加我QQ103630333
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 15:26:183楼 得分:20
    循环调用s.Accept();
    一般会起一个监听线程,线程在程序没退出时一直调用s.Accept(),如果有连接进来就拿到对应的Socket(temp),然后与通知处理线程,将temp交给它。
    普通模式是一个连接(temp)对应一个处理线程
    可以使用完成端口模式,启用线程池管理线程,将temp进行队列,线程池启动线程从temp队列中取出连接进行相应处理。
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 15:44:484楼 得分:0
    你可以收到一个包就开一线程,再记录这个线程,在服务端处理完后,再发给客户端,再把这个线程删掉
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 16:01:335楼 得分:0
    问题仍在想法解决中,能说具体一点么.最好能有代码提示
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    • Scarroot
    • 等级:
    发表于:2008-03-21 16:17:186楼 得分:10
    http://blog.csdn.net/zhiang75/archive/2004/08/16/75915.aspx
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 16:26:527楼 得分:0
    谢谢Scarroot给的博客,不过我还没测试,这两天看看能不能看懂^^
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 16:47:518楼 得分:0
    Scarroot给的博客里的代码,我发现我看不懂啊,不知道如何去用-_-
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 17:44:439楼 得分:0
    楼主 不行我给你一个源码吧 运行畅通。
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    • jzywh
    • 等级:
    发表于:2008-03-21 17:55:3210楼 得分:15
    把这些

      string recvStr = "";
                byte[] recvBytes = new byte[1024];
                int bytes;
                bytes = temp.Receive(recvBytes, recvBytes.Length, 0);//从客户端接受信息
                recvStr += Encoding.ASCII.GetString(recvBytes, 0, bytes);//获取字符串(字节数组,索引,字节数)

            /**////给client端返回信息
                Console.WriteLine("接收来自客户端的信息:{0}", recvStr);//把客户端传来的信息显示出来
                string sendStr = "ok!Client send message successful!";
                byte[] bs = Encoding.ASCII.GetBytes(sendStr);
                temp.Send(bs, bs.Length, 0);//返回信息给客户端
                temp.Close();
                s.Close();
                Console.ReadLine();


    放到Thread的start方法里面去就ok
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 17:57:0511楼 得分:0
    回复yilanwuyu123,能给我一个完整的例子当然好啦,先谢谢你拉,我的邮箱是calum0414@126.com
    修改 删除 举报 引用 回复
    进入用户个人空间
    加为好友
    发送私信
    在线聊天
    发表于:2008-03-21 17:57:5512楼 得分:0
    我憋了很久了-_-还没搞明白呢
    修改 删除 举报 引用 回复

    网站简介广告服务网站地图帮助联系方式诚聘英才English 问题报告
    北京创新乐知广告有限公司 版权所有 京 ICP 证 070598 号
    世纪乐知(北京)网络技术有限公司 提供技术支持
    Copyright © 2000-2008, CSDN.NET, All Rights Reserved