以太坊账户源码分析（以太坊开源代码）

8.c.encMu.Lock()。

9. 选择{。 //等待前面的读循环退出。 这是一个罕见的案例。

10.if回调！ =无{。

以太坊账户源码分析（以太坊开源代码）Part 2

1.默认：。 ifreq.err！ =无{。

2、2、RPC WebSocket服务，拨号实现方法：。

3.}此时请求被select阻塞，直到c.requestOpreceive到达op，或者receive到达ctx.Done()，或者receive到达c.didQuit。 c.requestOp获取op，调用write方法将请求内容写入conn通道。 然后发送给sendDonechan，客户端的dispatchch方法就会收到这个结果！

4. ifreq.isUnsubscribe{//取消订阅，第一个参数必须是订阅id。

5.先过滤掉非法请求，将接收到的请求体用JSONCodec封装！

6.s。 编解码器。 删除（编解码器）。

7.c。 处理通知（消息）。

8.回调（）。 }（请求，批次）。

9、

10.buf=buf[:0]。 }codec.ReadRequestHeaders() 解析请求数据。

以太坊账户源码分析（Ethereum Open Source Code）Part 3

1.c. 关闭请求操作（ErrClientQuit）。

2. ifdeadline, ok: = ctx. 最后期限（）; 行{。

3. ifstrings.HasSuffix(in.Method, unsubscribeMethodSuffix){.

4. 延迟关闭（op. resp）。

5. returnnil, false, &invalidRequestError{"Unabletoparsesubscriptionrequest"}。

6、二、RPC拨号的其他实现方法 RPCClient拨号过程的本质是在客户端和服务器之间建立一个读写通道！

7. ifreq.callb.errPos>=0{//测试方法返回错误。

8.此时将返回的数据发送给op.resp

9.然后交给srv.ServeSingleRequest(codec, OptionMethodInvocation)处理！

10. 回到 exec(ctxcontext.Context, codecServerCodec, req*serverRequest) 方法。 codec.Write(response) 序列化返回结果json！

以太坊账户源码分析（Ethereum Open Source Code）Part 4

1. returnnil, false, &invalidMessageError{err. 错误（）}。

2. //对于订阅响应以太坊开源代码，如果服务器启动订阅。

3、readRequest(codecServerCodec)方法再次处理rpcRequest，然后返回！

4.iferr:=json。 解组（incomingMsg，&in）； 呃！ =无{。

5. //readloop 停止运行，它将发出所有其他当前操作的信号。

6. 返回 newIPCConnection(ctx, endpoint)。

7.日志。 Debug(fmt.Sprintf("readerror%v\n", err)).

8. iflen(in.Payload)==0{.

9. 拨号器：=contextDialer(ctx)。

10. Op.resp以太坊账户源码分析（Ethereum Open Source Code）Part 5

1、在上一节中，我们尝试写了一个RPC请求的例子。 通过分析源码，我们知道了RPC服务的创建过程，HttpRPCserver的创建过程，HttpRPCClient的请求过程！

2.删除（c.respWait，字符串（id））。

3. ifsvc, ok=s.services[r.service];! ok { //rpcmethodisn'tavailable.

4. req.svcname, serviceMethodSeparator, req.callb.method.Name,.

5. //删除最后发送的响应处理程序。 在这里被移除了。

6. iferr。 错误（）！ ="结束"{。

7. iflen（要求参数）！ =len(req.callb.argTypes){.

8.案例

9. func(c*Client) 发送(ctxcontext.Context, op*requestOp, msginterface{}) error{.

10. e:=reply[req.callb.errPos].Interface().（错误）。

以太坊账户源码分析（Ethereum Open Source Code）Part 6

1.go-ethereum中有四种RPC。 HTTPRPC、InprocRPC、IPCRPC、WSRPC。 它们的主要实现逻辑在rpc/server.go和rpc/client.go中。 各自根据自己的实现方式派生出自己的客户端实例，建立自己的net.conn通道。 由于HTTPRPC是基于短链接请求的以太坊开源代码，所以实现方式和其他的不一样！

2. 缓冲区。 原始消息。

3. requests:=make([]*serverRequest, len(reqs)).

4. requests[i].args=args[1:]//firstoneisservice.methodname which is'an actualargument.