Question

如何用c#实现把socket接收的数据写入sqlserver数据库

Answer 1

Asp.net中C#使用Socket发送和接收TCP数据的方法。

具体程序代码如下：

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
namespace ConsoleApplication1
{
    public static class SocketTest
    {
        private static Encoding encode = Encoding.Default;
        /// <summary>
        /// 监听请求
        /// </summary>
        /// <param name="port"></param>
        public static void Listen(int port)
        {
            Socket listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            listenSocket.Bind(new IPEndPoint(IPAddress.Any, port));
            listenSocket.Listen(100);
            Console.WriteLine("Listen " + port + " ...");
            while (true)
            {
                Socket acceptSocket = listenSocket.Accept();
                string receiveData = Receive(acceptSocket, 5000); //5 seconds timeout.
                Console.WriteLine("Receive：" + receiveData);
                acceptSocket.Send(encode.GetBytes("ok"));
                DestroySocket(acceptSocket); //import
            }
        }
        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="host"></param>
        /// <param name="port"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public static string Send(string host, int port, string data)
        {
            string result = string.Empty;
            Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            clientSocket.Connect(host, port);
            clientSocket.Send(encode.GetBytes(data));
            Console.WriteLine("Send：" + data);
            result = Receive(clientSocket, 5000 * 2); //5*2 seconds timeout.
            Console.WriteLine("Receive：" + result);
            DestroySocket(clientSocket);
            return result;
        }
        /// <summary>
        /// 接收数据
        /// </summary>
        /// <param name="socket"></param>
        /// <param name="timeout"></param>
        /// <returns></returns>
        private static string Receive(Socket socket, int timeout)
        {
            string result = string.Empty;
            socket.ReceiveTimeout = timeout;
            List<byte> data = new List<byte>();
            byte[] buffer = new byte[1024];
            int length = 0;
            try
            {
                while ((length = socket.Receive(buffer)) > 0)
                {
                    for (int j = 0; j < length; j++)
                    {
                        data.Add(buffer[j]);
                    }
                    if (length < buffer.Length)
                    {
                        break;
                    }
                }
            }
            catch { }
            if (data.Count > 0)
            {
                result = encode.GetString(data.ToArray(), 0, data.Count);
            }
            return result;
        }
        /// <summary>
        /// 销毁Socket对象
        /// </summary>
        /// <param name="socket"></param>
        private static void DestroySocket(Socket socket)
        {
            if (socket.Connected)
            {
                socket.Shutdown(SocketShutdown.Both);
            }
            socket.Close();
        }
    }
}

Answer 2

socket 接收到的一般是字节数组，首先要把字节数组转换成你需要的值，然后insert到数据库就可以了

Answer 3

你的问题点在哪里？
无非是3个步骤，
1，建立socket连接，
2，取得数据，处理数据（解析，分类，等等）
3，存数据库。
请详细描述你的问题难点，以便于解答。

追问

我已经接收到数据了，然后给了一个变量，数据库的操作我也大体知道，就是不知道怎么把这个变量赋值进去，写入数据库。应该把数据库的操作写在哪里才可以用这个变量？

追答

我简单举例，你试着理解，

你取得了一个字符串 str，你想将str 插入到数据库 （mydb）中表（mytable）中

mytable表中有一个列（mycol）。

你的疑问就是不知道如何传递变量，对吗？

public class DbContext() //数据库操作类
{
    public void DbInsert(string sqlstr) //插入方法  参数是sql语句
    {
       //...你知道怎么操作DB的吧
       var conn = new SqlConnection()...blabla...
       conn.Open();
       //blabla....
       //***************就是这一句 ***********
       conn.CommandText = sqlstr;  //执行SQL语句
       //*************************
       conn.ExcuteNoquery();
       ....
       conn.CLose();
    }
}

先写好这么个类 里面带这么个方法，

然后你的SOCKET类，

public class Socket()
{
    public void ReciveData()假设接收SOCKET数据的方法是这个。
    {
        //...前面不管了，到这一步你拿到了一个变量，
        string str = "你接收到的 要存储的变量";
        string sql = $"insert into myTable (myCol) values ({str})";
        var db = new DbContext();
        db.DbInsert(sql);
        //后续....blablabla...
    }
}

就OK了。

Answer 4

既然你已经取到数据，并且把他赋值给一个变量了。 只需在数据库中建立个表。对应的存储进去啊！ 如果你还不懂得怎么进行数据存储。这个是对数据库的操作。 其中 CN 代表的是连接字符串
public int YG_mesageAdd(string YGname, string YGINtrodution, string iamgeAddess)
{
//设置标志位用来判断数据添加是否正确
int flage;
//实例化 sql 存储过程
SqlCommand cmd = new SqlCommand("YG_addMesage", cn);
cmd.CommandType = CommandType.StoredProcedure;
//需要添加的数据
SqlParameter[] param =
{
new SqlParameter("@YGname",YGname),
new SqlParameter("@YGINtrodution",YGINtrodution),
new SqlParameter("@iamgeAddess",iamgeAddess),
};
cmd.Parameters.AddRange(param);
// 执行操作
cn.Open();
flage = cmd.ExecuteNonQuery();
cn.Close();
return flage;

}

追问

我已经接收到数据了，然后给了一个变量，数据库的操作我也大体知道，就是不知道怎么把这个变量赋值进去，写入数据库。应该把数据库的操作写在哪里才可以用这个变量？