c#同步通信改异步,求代码如何修改?

using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

namespace DAL
{
///
/// Socket接口
///
static class socket
{
//Socket
private static Socket clientSocket;

    /// <summary>
    /// socket连接
    /// </summary>
    /// <returns>
    /// true    成功
    /// false   失败
    /// </returns>
    public static bool SocketConnect()
    {
        //从配置文件获取IP
        string SocketIP = DAL.Common.ReadConfigString("Recover", "IP");
        //从配置文件获取端口
        int SocketPort = Convert.ToInt32(DAL.Common.ReadConfigString("Recover", "Port"));
        try
        {
            //创建socket实例
            clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //创建IP地址
            IPAddress IP = IPAddress.Parse(SocketIP);
            //创建网络端点
            IPEndPoint ipEnd = new IPEndPoint(IP, SocketPort);
            //clientSocket.Blocking = false;
            //Socket连接
            clientSocket.Connect(ipEnd);

            if (clientSocket.Connected)
            {
                return true;
            }
            else
            {
                return false;
            }
        }
        catch (Exception e)
        {
            string strError = "";
            strError += "\r\n SocketIP = " + SocketIP.ToString();
            strError += "\r\n SocketPort = " + SocketPort.ToString();
            DAL.Common.WriteErrorLog(e, strError);
            return false;
        }
    }

    /// <summary>
    /// Socket发送数据
    /// </summary>
    /// <param name="strSend">
    /// 数据的内容
    /// </param>
    public static void SocketSend(string strSend)
    {
        try
        {
            Byte[] bytesSent = Encoding.UTF8.GetBytes(strSend);
            //按byte发送
            clientSocket.Send(bytesSent, bytesSent.Length, 0);
        }
        catch (Exception e)
        {
            string strError = "";
            DAL.Common.WriteErrorLog(e, strError);
        }
    }

    /// <summary>
    /// Socket接收数据
    /// </summary>
    /// <returns>
    /// 收到的数据
    /// </returns>
    public static string SocketReceive()
    {
        string result = "";
        try
        {
            MemoryStream stream = new MemoryStream();
            Byte[] bytesReceived = new Byte[256];
            int bytes = 0;
            do
            {
                bytes = clientSocket.Receive(bytesReceived, bytesReceived.Length, 0);
                stream.Write(bytesReceived, 0, bytes);
            }
            while (bytes > 0);
            result = System.Text.Encoding.UTF8.GetString(stream.ToArray());

            /*string strLogFile = System.AppDomain.CurrentDomain.BaseDirectory + "debug.txt";
            StreamWriter sw = new StreamWriter(strLogFile, true);
            sw.WriteLine(result);
            sw.WriteLine("\n------------------------------------------------------------------------\n");
            int len = stream.ToArray().Length;
            char[] tempchar = new char[len];
            byte[] tempbyte = new byte[len];
            tempbyte = stream.ToArray();
            for (int i = 0; i < len; i++)
            {
                tempchar[i] = (char)tempbyte[i];
            }
            sw.Write(tempchar);
            sw.WriteLine("\n------------------------------------------------------------------------\n");
            sw.Flush();
            sw.Close();*/


            //接收完毕后断开连接
            clientSocket.Close();
        }
        catch (Exception e)
        {
            string strError = "";
            DAL.Common.WriteErrorLog(e, strError);
        }
        return result;
    }

    /// <summary>
    /// Socket通信
    /// </summary>
    /// <param name="strSend">
    /// 发送的信息
    /// </param>
    /// <returns>
    /// 包体的内容
    /// </returns>
    public static string GetSocketData(string strSend)
    {
        string strDatas = "";
        string strResult = "";
        string strExtLength = "";
        try
        {
            //Socket连接
            SocketConnect();
            //发送信息
            SocketSend(strSend);
            //接收服务器的信息
            strResult = SocketReceive();
            //获取扩展信息的长度
            strExtLength = strResult.Substring(16, 12);
            int ExtLength = Convert.ToInt32(strExtLength);
            //扩展信息,暂不使用
            //string strExtInfo = strResult.Substring(32, ExtLength);
            //获取包体的内容
            strDatas = strResult.Substring(ExtLength + 32);

            //strDatas = decodedString;
        }
        catch (Exception e)
        {
            string strError = "";
            strError += "\r\n strResult = " + strResult;
            strError += "\r\n strExtLength = " + strExtLength;
            DAL.Common.WriteErrorLog(e, strError);
            strDatas = "";
        }
        return strDatas;
    }

1个回答

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐