当前位置：首页 > 行业动态 > 正文

c#socket连续接收数据库

admin
行业动态
2025-02-16
5

在C#中，使用Socket连续接收数据库可以通过创建持久的连接和循环读取数据来实现。

在C#中，使用Socket进行连续接收数据并存储到数据库是一个常见的需求，以下是一个详细的步骤和示例代码，展示如何实现这一功能：

创建数据库连接

需要创建一个数据库连接，这里以SQL Server为例，你可以根据实际使用的数据库类型进行调整。

using System;
using System.Data.SqlClient;
public class DatabaseHelper
{
    private static string connectionString = "Server=your_server;Database=your_database;User Id=your_username;Password=your_password;";
    public static SqlConnection GetConnection()
    {
        return new SqlConnection(connectionString);
    }
}

创建Socket服务器端

创建一个Socket服务器端，用于接收客户端发送的数据。

c#socket连续接收数据库

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
public class SocketServer
{
    private static TcpListener tcpListener;
    private static Thread listenThread;
    public static void StartListening()
    {
        listenThread = new Thread(new ThreadStart(ListenForClients));
        listenThread.Start();
    }
    private static void ListenForClients()
    {
        tcpListener = new TcpListener(IPAddress.Any, 8000);
        tcpListener.Start();
        while (true)
        {
            TcpClient client = tcpListener.AcceptTcpClient();
            Thread clientThread = new Thread(new ParameterizedThreadStart(HandleClientComm));
            clientThread.Start(client);
        }
    }
    private static void HandleClientComm(object client)
    {
        TcpClient tcpClient = (TcpClient)client;
        NetworkStream clientStream = tcpClient.GetStream();
        byte[] buffer = new byte[1024];
        int bytesRead;
        while ((bytesRead = clientStream.Read(buffer)) != 0)
        {
            string receivedData = Encoding.ASCII.GetString(buffer, 0, bytesRead);
            Console.WriteLine("Received: " + receivedData);
            SaveToDatabase(receivedData);
        }
        clientStream.Close();
        tcpClient.Close();
    }
    private static void SaveToDatabase(string data)
    {
        using (SqlConnection connection = DatabaseHelper.GetConnection())
        {
            string query = "INSERT INTO YourTable (YourColumn) VALUES (@data)";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                command.Parameters.AddWithValue("@data", data);
                connection.Open();
                command.ExecuteNonQuery();
            }
        }
    }
}

启动服务器并测试

在主程序中启动Socket服务器，并模拟客户端发送数据进行测试。

class Program
{
    static void Main(string[] args)
    {
        Console.WriteLine("Server is running...");
        SocketServer.StartListening();
        Console.ReadLine(); // Keep the server running
    }
}