web调用文档地址
const dayjs = require('dayjs')
const crypto = require('crypto');
const WebSocket = require('ws')
const APIKey = 'f0a2be46b8bdasdadasdasdasdasdasdcb'
const APISecret = 'OWU5NTA2MIHSADHZiYmM5NzI5OGUxYmUx'
const APPID = 'asda123xas'
const UID = 'test'
const host = 'spark-api.xf-yun.com'
const req_path = '/v1.1/chat'
const gmtDate = new Date().getTime() + ((new Date().getTimezoneOffset() / 60) * 60 * 60 * 1000)
const date = dayjs(gmtDate).format('ddd[,] DD MMM YYYY HH:mm:ss [GMT]')
// 利用上方的date动态拼接生成字符串tmp
const tmp = `host: ${host}\ndate: ${date}\nGET ${req_path} HTTP/1.1`
// 利用hmac-sha256算法结合APISecret对上一步的tmp签名,获得签名后的摘要tmp_sha
const tmp_sha = crypto.createHmac('sha256', APISecret).update(tmp).digest();
// 将上方的tmp_sha进行base64编码生成signature
const signature = tmp_sha.toString('base64')
// 利用上面生成的signature,拼接下方的字符串生成authorization_origin
const authorization_origin = `api_key="${APIKey}", algorithm="hmac-sha256", headers="host date request-line", signature="${signature}"`
// 最后再将上方的authorization_origin进行base64编码,生成最终的authorization
const authorization = Buffer.from(authorization_origin).toString('base64')
// 将鉴权参数组合成最终的键值对
const url = `wss://${host}${req_path}?authorization=${encodeURIComponent(authorization)}&date=${encodeURIComponent(date).replace(new RegExp('%20','g'), '+')}&host=${encodeURIComponent(host)}`
const ws = new WebSocket(url)
ws.on('error', (err) => {
console.log(err, '错误');
});
ws.on('open', function open() {
ws.send(JSON.stringify({
header: {
app_id: APPID,
uid: UID
},
parameter: {
chat: {
domain: "general",
temperature: 0.5,
max_tokens: 4096,
}
},
payload: {
message: {
text: [
{ role: 'user', 'content': '长白山适合什么时候去游玩,且有那可以景点推荐呢?' }
]
}
}
}));
});
ws.on('message', function message(data) {
const obj = JSON.parse(data)
const texts = obj.payload.choices.text
texts.forEach(item => {
console.log(item.content);
})
});
网友评论