首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >用Phoenix.js连接角度9

用Phoenix.js连接角度9
EN

Stack Overflow用户
提问于 2020-04-30 21:34:36
回答 1查看 387关注 0票数 0

我正试图将Angular 9作为一个客户端与phoenix.js连接起来,以连接到现有的凤凰频道。

首先,我通过cli命令创建了一个角应用程序,并通过npm install phoenix下载了凤凰。然后我在angular.json中添加了凤凰路径

代码语言:javascript
复制
 "scripts": [
              "./node_modules/phoenix/priv/static/phoenix.js"
            ]

然后我创建了一个服务

代码语言:javascript
复制
import { Injectable } from '@angular/core';
import { Phoenix } from 'phoenix';

declare var Socket: any;  // there is no typescript version of the package available so we cannot use a compile time import
declare var Phoenix: any;

@Injectable({
  providedIn: 'root'
})
export class PhoenixService {

  socket: any;

  constructor() {
    let socket = new Phoenix.Socket("wss://api.catalx.io/markets", {params: {}})
    socket.connect()

    let channel = socket.channel("updates:CAD-BTC", {})
    channel.on("new_msg", msg => console.log("Got message", msg) )
    channel.join()
      .receive("ok", ({messages}) => console.log("catching up", messages) )
      .receive("error", ({reason}) => console.log("failed join", reason) )
      .receive("timeout", () => console.log("Networking issue. Still waiting..."))
    channel.push("fetch", "market_state")
  }
}

最后,在AppComponent中调用此服务

代码语言:javascript
复制
export class AppComponent {

  constructor(private phoenixService: PhoenixService) {
    phoenixService.socket.connect();
  }
}

结果我得到了

core.js:6237 ERROR TypeError:无法读取未定义的新AppComponent (app.component.ts:14)属性“connect” 到'wss://api.catalx.io/markets/websocket?vsn=2.0.0‘的phoenix.js:1 WebSocket连接失败:在WebSocket握手期间出错:意外响应代码: 403

我想我遇到这些错误是因为PhoenixService不能抓取phoenix.js?小小的帮助是值得感激的!

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2020-04-30 23:00:52

我认为应该是这样的,如果您使用"npm i -S凤凰“安装js,则不需要在”脚本“中添加js。

无法使用catalx进行测试。

代码语言:javascript
复制
import { Injectable } from '@angular/core';
import { Socket as PhoenixSocket } from 'phoenix';

export const WEBSOCKET_SERVER_URI = 'wss://api.catalx.io/markets';

@Injectable({
  providedIn: 'root'
})
export class PhoenixService {
  phoenixSocket: PhoenixSocket;

  constructor() {
    this.phoenixSocket = new PhoenixSocket(
      WEBSOCKET_SERVER_URI,
      {
        params: {},
      }
    );
    this.phoenixSocket.connect();
  }
}
票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/61533123

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档