本文主要是介绍SQLserver通过CLR调用TCP接口,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
一、SQLserver启用CLR
- 查看是否开启CRL,如果run_value=1,则表示开启
EXEC sp_configure 'clr enabled';
GO
RECONFIGURE;
GO
- 如果未启用,则执行如下命令启用CLR
sp_configure 'clr enabled', 1;
GO
RECONFIGURE;
GO
二、创建 CLR 程序集
-
创建新项目
打开 Visual Studio,创建一个新的类库项目,命名为TcpClientWrapper,目标框架选择 .NET Framework 3.5。
-
编写 TCP 通信代码
在Class1.cs文件中添加如下代码
using System;
using System.Data.SqlTypes;
using System.IO;
using System.Net.Sockets;
using Microsoft.SqlServer.Server;public class TcpClientWrapper
{private static TcpClient client;[SqlFunction]public static SqlString CallTcpService(SqlString host, SqlInt32 port, SqlString message){try{if (client == null || !client.Connected){client = new TcpClient(host.Value, port.Value);}using (NetworkStream stream = client.GetStream()){using (var writer = new StreamWriter(stream))using (var reader = new StreamReader(stream)){// Send the message to the TCP server.writer.Write(message.Value);writer.Flush();// Read the response from the TCP server.int response = reader.Read();char character = Convert.ToChar(response);//string response = reader.ReadToEnd();return new SqlString(response + "_" + character);}}}catch (Exception ex){return new SqlString("Error: " + ex.Message);}}
}
- 编译项目
会在 {项目路径}/bin/debug 下生成DLL文件,
三、部署程序集到SQLserver
- 将生成的dll文件上传到SQLserver服务器上,记录文件路径
- 执行以下命令将程序集加载到 SQL Server
-- 因为程序中使用了静态成员变量,所以需要UNSAFE模式,否则会报错,建议使用SAFE、EXTERNAL_ACCESS模式
CREATE ASSEMBLY TcpClientWrapper FROM 'C:\test\TcpClientWrapper.dll' WITH PERMISSION_SET = UNSAFE;-- 删除 ASSEMBLY
DROP ASSEMBLY TcpClientWrapper;
- 创建函数以调用程序集中的方法
CREATE FUNCTION dbo.CallTcpService(@host NVARCHAR(255), @port INT, @message NVARCHAR(MAX))
RETURNS NVARCHAR(MAX)
AS EXTERNAL NAME TcpClientWrapper.[TcpClientWrapper].CallTcpService;
四、调用TCP接口
DECLARE @response NVARCHAR(MAX);
SET @response = dbo.CallTcpService('127.0.0.1', 8899, '好');
PRINT @response;
数据库端:
服务端:
这篇关于SQLserver通过CLR调用TCP接口的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!