AI 助理
文档备案控制台
开发者社区 人工智能 文章 正文

Socket编程 (连接,发送消息) (Tcp、Udp) - Part1

2013-05-16 1332
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 原文 http://www.cnblogs.com/zengqinglei/archive/2013/04/27/3046119.html Socket编程 (连接,发送消息) (Tcp、Udp)  本篇文章主要实现Socket在Tcp\Udp协议下相互通讯的方式。

原文 http://www.cnblogs.com/zengqinglei/archive/2013/04/27/3046119.html

Socket编程 (连接,发送消息) (Tcp、Udp) 

本篇文章主要实现Socket在Tcp\Udp协议下相互通讯的方式。(服务器端与客户端的通讯)

　　1.基于Tcp协议的Socket通讯类似于B/S架构，面向连接，但不同的是服务器端可以向客户端主动推送消息。

　　使用Tcp协议通讯需要具备以下几个条件：

　　　　(1).建立一个套接字(Socket)

　　　　(2).绑定服务器端IP地址及端口号--服务器端

　　　　(3).利用Listen()方法开启监听--服务器端

　　　　(4).利用Accept()方法尝试与客户端建立一个连接--服务器端

　　　　(5).利用Connect()方法与服务器建立连接--客户端

　　　　(5).利用Send()方法向建立连接的主机发送消息

　　　　(6).利用Recive()方法接受来自建立连接的主机的消息(可靠连接)

　　　　

 

　　2.基于Udp协议是无连接模式通讯，占用资源少，响应速度快，延时低。至于可靠性，可通过应用层的控制来满足。(不可靠连接)

　　　　(1).建立一个套接字(Socket)

　　　　(2).绑定服务器端IP地址及端口号--服务器端

　　　　(3).通过SendTo()方法向指定主机发送消息(需提供主机IP地址及端口)

　　　　(4).通过ReciveFrom()方法接收指定主机发送的消息(需提供主机IP地址及端口)

　　　　　　　　

上代码：由于个人代码风格，习惯性将两种方式写在一起，让用户主动选择Tcp\Udp协议通讯

服务器端：　　　

复制代码 
using System;
using System.Collections.Generic;
using System.Text;
#region 命名空间
using System.Net;
using System.Net.Sockets;
using System.Threading;
#endregion

namespace SocketServerConsole
{
    class Program
    {
        #region 控制台主函数
        /// <summary>
        /// 控制台主函数
        /// </summary>
        /// <param name="args"></param>
        static void Main(string[] args)
        {
            //主机IP
            IPEndPoint serverIP = new IPEndPoint(IPAddress.Parse("192.168.1.105"), 8686);
            Console.WriteLine("请选择连接方式：");
            Console.WriteLine("A.Tcp");
            Console.WriteLine("B.Udp");
            ConsoleKey key;
            while (true)
            {
                key = Console.ReadKey(true).Key;
                if (key == ConsoleKey.A) TcpServer(serverIP);
                else if (key == ConsoleKey.B) UdpServer(serverIP);
                else
                {
                    Console.WriteLine("输入有误,请重新输入：");
                    continue;
                }
                break;
            }
        }
        #endregion

        #region Tcp连接方式
        /// <summary>
        /// Tcp连接方式
        /// </summary>
        /// <param name="serverIP"></param>
        public static void TcpServer(IPEndPoint serverIP)
        {
            Console.WriteLine("客户端Tcp连接模式");
            Socket tcpServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            tcpServer.Bind(serverIP);
            tcpServer.Listen(100);
            Console.WriteLine("开启监听...");
            new Thread(() =>
            {
                while (true)
                {
                    try
                    {
                        TcpRecive(tcpServer.Accept());
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
                        break;
                    }
                }
            }).Start();
            Console.WriteLine("\n\n输入\"Q\"键退出。");
            ConsoleKey key;
            do
            {
                key = Console.ReadKey(true).Key;
            } while (key != ConsoleKey.Q);
            tcpServer.Close();
        }

        public static void TcpRecive(Socket tcpClient)
        {
            new Thread(() =>
            {
                while (true)
                {
                    byte[] data = new byte[1024];
                    try
                    {
                        int length = tcpClient.Receive(data);
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
                        break;
                    }
                    Console.WriteLine(string.Format("收到消息：{0}", Encoding.UTF8.GetString(data)));
                    string sendMsg = "收到消息！";
                    tcpClient.Send(Encoding.UTF8.GetBytes(sendMsg));
                }
            }).Start();
        }
        #endregion

        #region Udp连接方式
        /// <summary>
        /// Udp连接方式
        /// </summary>
        /// <param name="serverIP"></param>
        public static void UdpServer(IPEndPoint serverIP)
        {
            Console.WriteLine("客户端Udp模式");
            Socket udpServer = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
            udpServer.Bind(serverIP);
            IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 0);
            EndPoint Remote = (EndPoint)ipep;
            new Thread(() =>
            {
                while (true)
                {
                    byte[] data = new byte[1024];
                    try
                    {
                        int length = udpServer.ReceiveFrom(data, ref Remote);//接受来自服务器的数据
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
                        break;
                    }
                    Console.WriteLine(string.Format("{0} 收到消息：{1}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), Encoding.UTF8.GetString(data)));
                    string sendMsg = "收到消息！";
                    udpServer.SendTo(Encoding.UTF8.GetBytes(sendMsg), SocketFlags.None, Remote);
                }
            }).Start();
            Console.WriteLine("\n\n输入\"Q\"键退出。");
            ConsoleKey key;
            do
            {
                key = Console.ReadKey(true).Key;
            } while (key != ConsoleKey.Q);
            udpServer.Close();
        }
        #endregion
    }
}
复制代码

客户端：

　　

复制代码 
using System;
using System.Collections.Generic;
using System.Text;
#region 命名空间
using System.Net.Sockets;
using System.Net;
using System.Threading;
#endregion

namespace SocketClientConsole
{
    class Program
    {
        #region 控制台主函数
        /// <summary>
        /// 控制台主函数
        /// </summary>
        /// <param name="args"></param>
        static void Main(string[] args)
        {
            //主机IP
            IPEndPoint serverIP = new IPEndPoint(IPAddress.Parse("192.168.1.77"), 8686);
            Console.WriteLine("请选择连接方式：");
            Console.WriteLine("A.Tcp");
            Console.WriteLine("B.Udp");
            ConsoleKey key;
            while (true)
            {
                key = Console.ReadKey(true).Key;
                if (key == ConsoleKey.A) TcpServer(serverIP);
                else if (key == ConsoleKey.B) UdpClient(serverIP);
                else
                {
                    Console.WriteLine("输入有误,请重新输入：");
                    continue;
                }
                break;
            }
        }
        #endregion

        #region Tcp连接方式
        /// <summary>
        /// Tcp连接方式
        /// </summary>
        /// <param name="serverIP"></param>
        public static void TcpServer(IPEndPoint serverIP)
        {
            Console.WriteLine("客户端Tcp连接模式");
            Socket tcpClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                tcpClient.Connect(serverIP);
            }
            catch (SocketException e)
            {
                Console.WriteLine(string.Format("连接出错：{0}", e.Message));
                Console.WriteLine("点击任何键退出！");
                Console.ReadKey();
                return;
            }
            Console.WriteLine("客户端：client-->server");
            string message = "我上线了...";
            tcpClient.Send(Encoding.UTF8.GetBytes(message));
            Console.WriteLine(string.Format("发送消息：{0}", message));
            new Thread(() =>
            {
                while (true)
                {
                    byte[] data = new byte[1024];
                    try
                    {
                        int length = tcpClient.Receive(data);
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
                        break;
                    }
                    Console.WriteLine(string.Format("{0} 收到消息：{1}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), Encoding.UTF8.GetString(data)));
                }
            }).Start();
            Console.WriteLine("\n\n输入\"Q\"键退出。");
            ConsoleKey key;
            do
            {
                key = Console.ReadKey(true).Key;
            } while (key != ConsoleKey.Q);
            tcpClient.Close();
        }
        #endregion

        #region Udp连接方式
        /// <summary>
        /// Udp连接方式
        /// </summary>
        /// <param name="serverIP"></param>
        public static void UdpClient(IPEndPoint serverIP)
        {
            Console.WriteLine("客户端Udp模式");
            Socket udpClient = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
            string message = "我上线了...";
            udpClient.SendTo(Encoding.UTF8.GetBytes(message), SocketFlags.None, serverIP);
            Console.WriteLine(string.Format("发送消息：{0}", message));
            IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
            EndPoint Remote = (EndPoint)sender;
            new Thread(() =>
            {
                while (true)
                {
                    byte[] data = new byte[1024];
                    try
                    {
                        int length = udpClient.ReceiveFrom(data, ref Remote);//接受来自服务器的数据
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
                        break;
                    }
                    Console.WriteLine(string.Format("{0} 收到消息：{1}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), Encoding.UTF8.GetString(data)));
                }
            }).Start();
            Console.WriteLine("\n\n输入\"Q\"键退出。");
            ConsoleKey key;
            do
            {
                key = Console.ReadKey(true).Key;
            } while (key != ConsoleKey.Q);
            udpClient.Close();
        }
        #endregion
    }
}
复制代码

Tcp协议下通讯效果如下图：

　　客户端：

　　

　　服务器端：

　　

 

基于Udp协议下通讯效果如下图：

　　客户端：

　　

　　服务器端：

　　

 

总结：Tcp协议相对通讯来说相对可靠，信息不易丢失,Tcp协议发送消息，发送失败时会重复发送消息等原因。所以对于要求通讯安全较高的程序来 说，选择Tcp协议的通讯相对合适。Upd协议通讯个人是比较推荐的，占用资源小，低延时，响应速度快。至于可靠性是可以通过一些应用层加以封装控制得到 相应的满足。

 

附上源码：Socket-Part1.zip

作者：曾庆雷
出处：http://www.cnblogs.com/zengqinglei
本页版权归作者和博客园所有，欢迎转载，但未经作者同意必须保留此段声明， 且在文章页面明显位置给出原文链接，否则保留追究法律责任的权利
文章标签：
网络协议
机器学习/深度学习
安全
杰克.陈
目录
相关文章
游客nf5px6uji34uk
|
网络协议 安全 网络安全
什么是TCP/UDP/HTTP？它们如何影响你的内网穿透体验？
数据的传输离不开各种协议，它们就像现实世界中的交通规则，规定了数据如何打包、寻址、传输和接收。对于使用内网穿透的用户来说，理解TCP、UDP和HTTP这些基础协议的特点，能帮助你更好地理解其性能表现，并选择最适合的配置方案。
游客nf5px6uji34uk
1722 0
卓伊凡
|
网络协议 安全 网络安全
详细阐述 TCP、UDP、ICMPv4 和 ICMPv6 协议-以及防火墙端口原理优雅草卓伊凡
详细阐述 TCP、UDP、ICMPv4 和 ICMPv6 协议-以及防火墙端口原理优雅草卓伊凡
卓伊凡
848 2
JackJiang2026
|
网络协议 Java 开发工具
全平台开源即时通讯IM框架MobileIMSDK：7端+TCP/UDP/WebSocket协议，鸿蒙NEXT端已发布，5.7K Stars
全平台开源即时通讯IM框架MobileIMSDK：7端+TCP/UDP/WebSocket协议，鸿蒙NEXT端已发布，5.7K Stars
JackJiang2026
957 1
游客4ajxjr2o23cj2
|
监控 API 开发工具
Socket.IO介绍，以及怎么连接测试Socket.IO接口？
Socket.IO 是一个用于浏览器和服务器间实时双向通信的库，支持低延迟消息传递、跨平台运行及自动重连。文章介绍了其特点与调试需求，并详细说明如何使用 Apifox 工具创建、连接、发送/接收 Socket.IO 事件，以及团队协作和调试技巧。掌握这些技能可提升实时应用开发效率与质量。
游客4ajxjr2o23cj2
1113 0
技术内容小助手
|
监控 网络协议 网络性能优化
不再困惑！一文搞懂TCP与UDP的所有区别
本文介绍网络基础中TCP与UDP的区别及其应用场景。TCP是面向连接、可靠传输的协议，适用于HTTP、FTP等需要保证数据完整性的场景；UDP是无连接、不可靠但速度快的协议，适合DNS、RIP等对实时性要求高的应用。文章通过对比两者在连接方式、可靠性、速度、流量控制和数据包大小等方面的差异，帮助读者理解其各自特点与适用场景。
技术内容小助手
2426 2
运维有小邓
|
存储 网络协议 安全
用于 syslog 收集的协议：TCP、UDP、RELP
系统日志是从Linux/Unix设备及网络设备生成的日志，可通过syslog服务器集中管理。日志传输支持UDP、TCP和RELP协议。UDP无连接且不可靠，不推荐使用；TCP可靠，常用于rsyslog和syslog-ng；RELP提供可靠传输和反向确认。集中管理日志有助于故障排除和安全审计，EventLog Analyzer等工具可自动收集、解析和分析日志。
运维有小邓
1538 2
东方睿赢
|
网络协议 开发者 Python
深度探索Python Socket编程：从理论到实践，进阶篇带你领略网络编程的魅力！
【7月更文挑战第25天】在网络编程中, Python Socket编程因灵活性强而广受青睐。本文采用问答形式深入探讨其进阶技巧。**问题一**: Socket编程基于TCP/IP,通过创建Socket对象实现通信,支持客户端和服务器间的数据交换。**问题二**: 提升并发处理能力的方法包括多线程(适用于I/O密集型任务)、多进程(绕过GIL限制)和异步IO(asyncio)。**问题三**: 提供了一个使用asyncio库实现的异步Socket服务器示例,展示如何接收及响应客户端消息。通过这些内容,希望能激发读者对网络编程的兴趣并引导进一步探索。
东方睿赢
462 4
龙大吉
|
开发者 Python
Python Socket编程：不只是基础，更有进阶秘籍，让你的网络应用飞起来！
【7月更文挑战第25天】在网络应用蓬勃发展的数字时代，Python凭借其简洁的语法和强大的库支持成为开发高效应用的首选。本文通过实时聊天室案例，介绍了Python Socket编程的基础与进阶技巧，包括服务器与客户端的建立、数据交换等基础篇内容，以及使用多线程和异步IO提升性能的进阶篇。基础示例展示了服务器端监听连接请求、接收转发消息，客户端连接服务器并收发消息的过程。进阶部分讨论了如何利用Python的`threading`模块和`asyncio`库来处理多客户端连接，提高应用的并发处理能力和响应速度。掌握这些技能，能使开发者在网络编程领域更加游刃有余，构建出高性能的应用程序。
龙大吉
335 3
众所周知
|
网络协议 Python
网络世界的建筑师：Python Socket编程基础与进阶，构建你的网络帝国！
【7月更文挑战第26天】在网络的数字宇宙中，Python Socket编程是开启网络世界大门的钥匙。本指南将引领你从基础到实战，成为网络世界的建筑师。
众所周知
383 2
土木林森
|
网络协议 程序员 视频直播
Python Socket编程秘籍：从基础概念到实战应用，助你成为网络编程高手！
【7月更文挑战第26天】
土木林森
577 2

热门文章

最新文章

  • 1
    2.8 基于DPDK的UDP用户态协议栈实现
  • 2
    arp、ethernet、icmp、udp、ip协议的C语言实现（计算机网络协议栈实验）
  • 3
    Netty网络编程（五）：使用UDP协议
  • 4
    在Linux中，我们都知道，dns采用了tcp协议，又采用了udp协议，什么时候采用tcp协议？什么 时候采用udp协议？为什么要这么设计？
  • 5
    UDP通信(一)
  • 6
    netty系列之:使用UDP协议
  • 7
    全平台开源即时通讯IM框架MobileIMSDK：7端+TCP/UDP/WebSocket协议，鸿蒙NEXT端已发布，5.7K Stars
  • 8
    NB-loT 通信之 UDP 收发数据 | 学习笔记
  • 9
    UDP通信
  • 10
    玩转UDP用户原语，这篇文章就够了【Verilog高级教程】
  • 1
    Socket-TCP 上位机下位机数据交互框架
    542
  • 2
    基于C#实现的支持文件传输的Socket聊天室
    601
  • 3
    区分TCP/IP、HTTP、Socket三者的差异
    1244
  • 4
    WebSocket、Socket、TCP 和 HTTP 的差别与应用场景
    3554
  • 5
    阿里云PAI-DLC任务Pytorch launch_agent Socket Timeout问题源码分析
    830
  • 6
    【YashanDB知识库】YAS-00402 failed to connect socket, errno 111
    301
  • 7
    【YashanDB知识库】查询空间数据提示This socket has been closed.
    328
  • 8
    【YashanDB知识库】YAS-00402 failed to connect socket, errno 111, error message "Connection refused"
    382
  • 9
    Socket如何实现客户端和服务器间的通信
    818
  • 10
    # 2个类轻松构建高效Socket通信库
    464

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！