时间戳

首页 > 解决方案 > 如何使用 Web 套接字在 Angular 应用程序和 composer-rest-server 之间进行通信？

websocket - 如何使用 Web 套接字在 Angular 应用程序和 composer-rest-server 之间进行通信？

问题描述

当我生成 Hyperledger Composer REST 服务器时（请参阅https://hyperledger.github.io/composer/latest/integrating/getting-started-rest-api），我可以选择指定是否要通过 WebSockets 启用事件发布（是/否）。

使用命令

yo hyperledger-composer

我使用生成的休息服务器生成了一个角度应用程序。

我期望的是以下内容：

如果我没有通过 WebSockets 为 composer-rest-server 启用事件发布，那么 angular 应用程序（为此 composer-rest-server 生成）将使用正常的 http 请求来联系 composer-rest-server。

这个期望得到了满足。Angular 应用程序中的（自动生成的）文件 data.service.ts 使用正常的 http 请求来联系服务器。以下是该文件的摘录：

public getAll(ns: string): Observable<Type[]> {
    console.log('GetAll ' + ns + ' to ' + this.actionUrl + ns);
    return this.http.get(`${this.actionUrl}${ns}`)
      .map(this.extractData)
      .catch(this.handleError);
}

public getSingle(ns: string, id: string): Observable<Type> {
    console.log('GetSingle ' + ns);

    return this.http.get(this.actionUrl + ns + '/' + id + this.resolveSuffix)
      .map(this.extractData)
      .catch(this.handleError);
}

public add(ns: string, asset: Type): Observable<Type> {
    console.log('Entered DataService add');
    console.log('Add ' + ns);
    console.log('asset', asset);

    return this.http.post(this.actionUrl + ns, asset)
      .map(this.extractData)
      .catch(this.handleError);
}

我的另一个期望是：

如果我确实通过 WebSockets 为 composer-rest-server 启用事件发布，那么 Angular 应用程序（为此 composer-rest-server 生成）将使用 websockets 来联系 composer-rest-server。

这个期望没有得到满足。Angular 应用程序中的（自动生成的）文件 data.service.ts 看起来完全相同（与是否为启用或禁用 Web 套接字的 composer-rest-server 生成 Angular 应用程序无关）。也就是说，使用普通的 http 请求来联系服务器。

这是为什么？如果我想使用网络套接字（用“ws”代替“http”），我是否必须手动更改文件“data.service.ts”中的代码，或者我在这里遗漏了什么？

标签： websockethyperledger-composer

解决方案

是的，你会替代。所以你的 websockets 服务器在ws://localhost:3000. 然后您使用 WS 客户端订阅事件（您可以wscat用作 WS 客户端来测试 - 即发布事件然后看到客户端接收事件）。见https://hyperledger.github.io/composer/latest/integrating/publishing-events.html

或写类似：

var ws = new WebSocket('ws://www.your.server.com');


ws.on('message', function incoming(data) {
  console.log(data);
});

// or 

ws.onmessage = function (event) {
  console.log(event.data);
}

ETC

推荐阅读