C#-Socket监听消息处理

TCP/IP:Transmission Control Protocol/Internet Protocol,传输控制协议/因特网互联协议,又名网络通讯协议。简单来说:TCP控制传输数据,负责发现传输的问题,一旦有问题就发出信号,要求重新传输,直到所有数据安全正确地传输到目的地,而IP是负责给因特网中的每一台电脑定义一个地址,以便传输。TCP协议在许多分布式应用程序中进行消息命令传递是必不可少的部分。

TCP通信的三次握手:三次握手(Three-way Handshake),是指建立一个TCP连接时,需要客户端和服务器总共发送3个包。

  1. 第一次握手:客户端发送一个TCP的SYN标志位置1的包指明客户打算连接的服务器的端口,以及初始序号X,保存在包头的序列号(Sequence Number)字段里。
  2. 第二次握手:服务器发回确认包(ACK)应答。即SYN标志位和ACK标志位均为1同时,将确认序号(Acknowledgement Number)设置为客户的I S N加1以.即X+1。
  3. 第三次握手:客户端再次发送确认包(ACK) SYN标志位为0,ACK标志位为1.并且把服务器发来ACK的序号字段+1,放在确定字段中发送给对方.并且在数据段放写ISN的+1

先看下服务端Socket监听代码:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace SocketDome
{
    /// <summary>
    /// 处理Socket监听逻辑
    /// </summary>
    public class SocketProvider
    {
        private static Socket serviceSocketListener; //Socke监听处理请求

        /// <summary>
        /// 开启Socket监听
        /// </summary>
        public static void Init()
        {
            serviceSocketListener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            serviceSocketListener.Bind(new IPEndPoint(IPAddress.Parse("10.0.0.217"), 20000)); //IP和端口应该是可配置
            serviceSocketListener.Listen(1024);
            Thread handleSocket = new Thread(new ThreadStart(HandleSocket));
            handleSocket.Start();
        }

        /// <summary>
        /// 监听链接
        /// </summary>
        private static void HandleSocket()
        {
            while (true)
            {
                try
                {
                    Socket currSocket = serviceSocketListener.Accept();  //为新建连接创建新的 System.Net.Sockets.Socket
                    Thread processThread = new Thread(new ParameterizedThreadStart(ProcessSocket));
                    processThread.Start(currSocket);
                }
                catch { }
            }
        }

        /// <summary>
        /// 处理Socket信息
        /// </summary>
        /// <param name="obj">新建连接创建新Socket对象</param>
        private static void ProcessSocket(object obj)
        {
            Socket currSocket = (Socket)obj;
            try
            {
                byte[] recvBytess = new byte[1048576];
                int recbytes;
                recbytes = currSocket.Receive(recvBytess, recvBytess.Length, 0);
                if (recbytes > 0)
                {
                    var contentStr = Encoding.UTF8.GetString(recvBytess, 0, recbytes);
                    var _order = contentStr.Split(‘~‘);
                    byte[] sendPass = Encoding.UTF8.GetBytes(_order[0].ToUpper() + "#SUCCESS"); //先相应对话,然后去异步处理
                    currSocket.Send(sendPass, sendPass.Length, SocketFlags.None);
                    switch (_order[0].ToUpper())
                    {
                        case"ADDCACHE":
                            Console.WriteLine("添加缓存消息" + _order[1]);
                           //处理ADDCACHE逻辑
                           Console.WriteLine("写Log日志");
                            break;
                        default :
                            Console.WriteLine("命令错误");
                            Console.WriteLine("写Log日志");
                            break;
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("写Error日志" + ex.Message);
            }
        }
    }
}

这个服务端,监听着客户端发来的命令,格式定义为:命令~参数,在服务端接受到客户端的命令消息后立即回传接到命令并开始处理,进行异步处理避免客户端等待。

下面看下客户端的Socket客户端主动请求服务端代码:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace ConsoleApplication7
{
    /// <summary>
    /// Socket Helper
    /// </summary>
    public class SocketHelper
    {
        private string ip;
        private IPEndPoint ex;
        private Socket socket;

        public SocketHelper(string ip, int port)
        {
            socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            this.ip = ip;
            this.ex = new IPEndPoint(IPAddress.Parse(ip), port);
        }

        /// <summary>
        /// Socket 进行连接
        /// </summary>
        /// <returns>连接失败OR成功</returns>
        public bool Socketlink()
        {
            try
            {
                socket.Connect(ex);
                return true;
            }
            catch (Exception ex)
            {
                return false;
            }
        }

        /// <summary>
        /// Socket 发送消息
        /// </summary>
        /// <param name="strmsg">消息</param>
        public void SendVarMessage(string strmsg)
        {
            try
            {
                byte[] msg = System.Text.Encoding.UTF8.GetBytes(strmsg);
                this.socket.Send(msg);
            }
            catch (Exception ex)
            {
                this.socket.Close();
            }
        }

        /// <summary>
        /// Socket 消息回传
        /// </summary>
        /// <returns></returns>
        public string ReceiveMessage()
        {
            try
            {
                byte[] msg = new byte[1048576];
                int recv = socket.Receive(msg);
                this.socket.Close();
                return System.Text.Encoding.UTF8.GetString(msg, 0, recv);
            }
            catch (Exception ex)
            {
                this.socket.Close();
                return "ERROR";
            }
        }
    }
}
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace ConsoleApplication7
{
    class Program
    {
        static void Main(string[] args)
        {
            SocketHelper socket = new SocketHelper("10.0.0.217",20000);
            if(socket.Socketlink())
            {
                Console.WriteLine("连接成功");
                socket.SendVarMessage("ADDCACHE~张三");
                string strReposon = socket.ReceiveMessage();
                Console.WriteLine(strReposon);
            }
            Console.Read();
        }
    }
}

首先以管理园身份开启服务端查询,然后客户端主动请求服务端进行消息请求。

时间: 2024-11-08 03:15:25

C#-Socket监听消息处理的相关文章

【网络通信】服务器端Socket监听80端口,建立连接传输数据时也是使用的80端口么?

1. 服务器端Socket监听80端口,建立连接传输数据时也是使用的80端口么? 答:对.建立连接时服务器会分配一个新的Socket,但是用的源端口号还是80端口.套接字是由协议类型.源IP.目的IP和源端口.目的端口五部分组成的,理论上讲,不同连接的套接字只要满足这五部分不完全相同即可.只要不完全相同,收发数据时就能区分不同连接的数据. 附:这也是通过tcpdump等网络抓包工具抓取服务器监听端口的数据可以抓取到该服务下所有连接的网络包的原因所在. 2.使用同一端口号收发数据,是不是会导致带宽

Tomcat服务器无法启动socket监听端口

最近生成一个新的web服务器,在启动后无法启动socket监听,检查程序本身无问题, 找原因,只是发布时搞错.处理如下: 1.在Eclipse平台 删除原来的web server; 2.新建server 3.删除tomcat服务器conf目录 下所有文件,server下的config文件到该目录: 4.删除tomcat服务器webapps 下项目.war 及对应目录,拷新 项目.war.

JavaWeb服务启动时,在后台启动加载一个线程进行Socket监听端口

最近,做一个项目,需要做一个web服务器,该服务器要与Android端和GPRS模块互相通信.考虑Android端与服务器端用Http通信,GPRS模块与服务器用Tcp通信.因此需要在Web服务器启动的时候启动加载一个线程负责Tcp端口的监听. search了一些方法,从中挑选了两个在此记录一下: 方法一:监听(Listener) 我们创建一个监听类,继承自ServletContextListener,代码如下: 1 package will; 2 3 4 import java.io.IOEx

web socket多线程实时监听

配置文件: web.xml文件: <!-- socket 监听 --> <context-param> <param-name>socketPort</param-name> <param-value>8888</param-value> </context-param> <listener> <description>Socket</description> <listener-

为什么有监听socket和连接socket,为什么产生两个socket

为什么有监听socket和连接socket,为什么产生两个socket 先看一半的socket建立连接的双方的过程: 客户端: socket()---->创建出 active_socket_fd (client_socket_fd) bind()--->把active_socket_fd与ip,port绑定起来 connect()--->client_socket_fd 主动请求服务端的 listen_socket_fd read()/write()---->读/写 socket

iptables 完成联网控制 (续) ,独立native进程监听。

上一篇:http://www.cnblogs.com/oscar1011/p/5243877.html 之前做的iptables 来进行的联网控制,一直耿耿于怀,想要知道系统里的netd等等是如何做到执行那些命令,并能监听的. 最近有机会又对这部分进行了一些研究. 所要做的大概就是3部分,1. native进程,这部分得用c/c++来写,   2. framework接口.用于和native进程通信.   3. selinux权限配置,主要就是为了赋予natvie进程 framework与nat

C# 利用socekt做到http监听,怎么样才能做到高性能

c#原始提供了http的监听的类HttpListener,实现了简单的http.文章地址<C# 控制台或者winform程序开启http的监听状态> 但是经过我测试,这个HttpListener提供的真的就只是简单的http监听功能,无法实现高并发处理. 不知道是我处理问题还是其他什么原因,无法实现,当上一个http请求连接尚未关闭的情况下,即便是把请求放到另外一个线程执行,都要等到处理结束,close了才能接受和处理下一次的连接请求. 也许你会说HttpListener不是提供了异步监听的嘛

一个基于Socket的http请求监听程序实现

首先来看以下我们的需求: 用java编写一个监听程序,监听指定的端口,通过浏览器如http://localhost:7777来访问时,可以把请求到的内容记录下来,记录可以存文件,sqlit,mysql数据库,然后把接受到的信息在浏览器中显示出来 要点: Socket,线程,数据库,IO操作,观察者模式 来看下我们如何来设计这个小系统,这个系统包含三部分的内容,一个是监听端口,二是记录日志,三是数据回显,端口监听第一想到的就是Socket编程了,数据回显也是一样的,无非是把当前请求客户端的sock

Nginx 中 fastcgi_pass 监听端口 unix socket和tcp socket差

Nginx 中 fastcgi_pass 监听端口 unix socket和tcp socket差别 Nginx连接fastcgi的方式有2种:unix domain socket和TCP,Unix domain socket 或者 IPC socket是一种终端,可以使同一台操作系统上的两个或多个进程进行数据通信.与管道相比,Unix domain sockets 既可以使用字节流和数据队列,而管道通信则只能通过字节流.Unix domain sockets的接口和Internet socke