Dial

用于原始的Socket访问，支持tcp、udp、tls、unix协议。

支持4种流行的通信协议：mqtt、nats、amqp、kafka。

支持连接数据库，支持的数据库包括：sqlite3、mysql、postgres、clickhouse。

    
    
    
Dial(address)

    
    
    
Dial(address, timeout)

    
    
    
Dial(address, options)

示例

• Dial函数调用示例：

  • javascript
  • python
  • cpp

  
      javascript
      
      
  function main(){
      // Dial支持tcp://、udp://、tls://、unix://协议，可添加一个参数指定超时秒数
      var client = Dial("tls://www.baidu.com:443")
      if (client) {
          // write可再添加一个数字参数指定超时，write返回成功发送的字节数
          client.write("GET / HTTP/1.1\nConnection: Closed\n\n")
          while (true) {
              // read可再添加一个数字参数指定超时，单位：毫秒。返回null表示错误、超时或socket已关闭
              var buf = client.read()
              if (!buf) {
                  break
              }
              Log(buf)
          }
          client.close()
      }
  }
  

  
      python
      
      
  def main():
      client = Dial("tls://www.baidu.com:443")
      if client:
          client.write("GET / HTTP/1.1\nConnection: Closed\n\n")
          while True:
              buf = client.read()
              if not buf:
                  break
              Log(buf)
          client.close()
  

  
      c++
      
      
  void main() {
      auto client = Dial("tls://www.baidu.com:443");
      if(client.Valid) {
          client.write("GET / HTTP/1.1\nConnection: Closed\n\n");
          while(true) {
              auto buf = client.read();
              if(buf == "") {
                  break;
              }
              Log(buf);
          }
          client.close();
      }
  }
  

• Dial函数连接数据库时返回的连接对象具有2个独有的方法：

  - exec(sqlString): 用于执行SQL语句，使用方式类似于DBExec()函数。

  - fd(): fd()函数返回一个句柄（例如：句柄变量为handle），用于其他线程重连（即使Dial创建的对象已经执行close()函数关闭连接），将句柄传入Dial()函数，例如：Dial(handle)重用连接。

  以下是Dial函数连接sqlite3数据库的示例。

  • javascript
  • python
  • cpp

  
      javascript
      
      
  var client = null
  function main() {
      // client = Dial("sqlite3://:memory:")   // 使用内存数据库
      client = Dial("sqlite3://test1.db")      // 打开/连接托管者所在目录的数据库文件
  
      // 记录句柄
      var sqlite3Handle = client.fd()
      Log("sqlite3Handle:", sqlite3Handle)
  
      // 查询数据库中的表
      var ret = client.exec("SELECT name FROM sqlite_master WHERE type='table'")
      Log(ret)
  }
  
  function onexit() {
      Log("执行client.close()")
      client.close()
  }
  

  
      python
      
      
  // 不支持

  
      c++
      
      
  // 不支持

返回值

参数

备注

address参数的详细说明：在标准地址wss://xxx.xxx.xxx:10441/websocket?compress后，使用|符号作为分隔符。如果参数字符串中包含|字符，则使用||作为分隔符。分隔符后的部分为功能参数设置，各参数之间使用&字符连接。

例如，同时设置socks5代理和压缩参数时可以写作：

Dial("wss://baidu.com/stream|proxy=socks5://xxx:9999&compress=gzip_raw&mode=recv")

Dial()函数仅支持实盘环境。

使用Dial函数连接数据库时，连接字符串的编写请参考各数据库的Go语言驱动项目。

目前仅JavaScript语言支持Dial函数中使用mqtt、nats、amqp、kafka通信协议。以下为JavaScript语言策略代码示例，展示mqtt、nats、amqp、kafka四种协议的使用方法：

            javascript
            
            
// 需要先配置、部署完成各个协议的代理服务器
// 为了便于演示，主题test_topic的订阅（read操作）、发布（write操作）都在当前这个策略中进行

var arrConn = []
var arrName = []

function main() {
    LogReset(1)
    conn_nats = Dial("nats://admin@127.0.0.1:4222?topic=test_topic")
    conn_mqtt = Dial("mqtt://127.0.0.1:1883?topic=test_topic")
    conn_amqp = Dial("amqp://q:admin@127.0.0.1:5672/?queue=test_Queue")
    conn_kafka = Dial("kafka://localhost:9092/test_topic")
    arrConn = [conn_nats, conn_amqp, conn_mqtt, conn_kafka]
    arrName = ["nats", "amqp", "mqtt", "kafka"]

    while (true) {
        for (var i in arrConn) {
            var conn = arrConn[i]
            var name = arrName[i]

            // 写数据
            conn.write(name + ", time: " + _D() + ", test msg.")

            // 读数据
            var readMsg = conn.read(1000)
            Log(name + " readMsg: ", readMsg, "#FF0000")
        }

        Sleep(1000)
    }
}

function onexit() {
    for (var i in arrConn) {
        arrConn[i].close()
        Log("关闭", arrName[i], "连接")
    }
}

Dial函数用于访问WebSocket接口时，支持设置WSS请求头：

            javascript
            
            
let options = {"headers": {"Authorization": "Bearer token123"}}
let conn = Dial("wss://api.example.com/ws", options)

            python
            
            
options = {"headers": {"Authorization": "Bearer token123"}}
conn = Dial("wss://api.example.com/ws", options)

            c++
            
            
// 暂不支持