java区块链开源代码,java区块链开发教程

2022-07-31 15:10:54 分类：java 阅读()

　　java区块链开源代码,java区块链开发教程

　　00-1010前言部署组件愚蠢部署获取部署包效果预览部署中遇到的问题：网关中的异常结论

　　

目录

jdchain是京东数码分公司的开源区块链平台。其目标是实现一个面向企业应用场景的通用区块链框架体系，作为企业级基础设施，为业务创新提供高效、灵活、安全的解决方案。

 

　　之所以选择jdchain进行研究，是因为jdchain是为数不多的底层，是java实现的区块链平台。

　　项目地址：https://github.com/blockchain.

　　文件地址：https://gitee.com/jdchain

　　

前言

peer:区块链的主节点，参与共识和账簿操作等。网关：与对等节点通信，负责区块链浏览器和消息客户端：使用SDK和gateway link通过网关发起事务。

 

　　

部署组件

 

　　00-1010获取部署包有两种方式。第一，直接从官网下载。第二，从github拉源代码，自己构建。部署包将在部署目录中生成。如果是自己建的，就要注意了。如果是在Windows上构建的包，包中的启动脚本在linux下运行时会有转义字符的问题，所以需要在assembly.xml中将lineEnding设置为unix

　　00-1010区块链部署工具

　　区块链浏览器

　　00-1010的官方文件比较详细，但是很多细节没有说明。开发期间的一般体验和部署环境相对简单，因此可以在一台主机上部署4节点对等机。这时候就要非常注意端口的排列了，因为jdchain目前的共识算法采用的是开源的bftsmart实现，共识端口在同一台主机上不能连续，否则端口会冲突。Blogger遇到了这个问题，以下是详细的故障排除过程：使用SDK创建用户时，抛出以下异常，网关可以正常连接，密钥认证没有问题：

　　导致： Java . lang . indexoutofboundsexception :访问索引超出BytesSlice的界限！at com . JD . block chain . utils . io . bytes slice . check boundary(bytes slice . Java :174)at com . JD . block chain . utils . io . bytes slice . getint(bytes slice . Java 336097)at com . JD . block chain . utils . io . bytes slice . getint(bytes slice . Java 336086)at com . JD . block chain . binary proto . impl . header encoder . resolve.7更

　　

傻瓜式部署

11:57:05.537错误com . JD . block chain . gateway . web . gatewayglobaexceptionhandler 34 JSON-出现意外异常！-[request URL=[POST]http://192 . 168 . 1 . 190:8081/RPC/tx][class Java . lang . illegalstateexception]返回的对象当前不属于此池Java . lang . illegalstateexception :返回的对象当前不属于此池org . Apache.commo ns . pool 2 . impl . genericobjectpool . return object(genericobjectpool . Java 3360530)~[commons

 

　　-pool2-2.5.0.jar!/:2.5.0]at com.jd.blockchain.consensus.bftsmart.client.BftsmartMessageService.sendOrderedMessage(BftsmartMessageService.java:46) ~[consensus-bftsmart-1.1.1.RELEASE.jar!/:1.1.1.RELEASE]at com.jd.blockchain.consensus.bftsmart.client.BftsmartMessageService.sendOrdered(BftsmartMessageService.java:22) ~[consensus-bftsmart-1.1.1.RELEASE.jar!/:1.1.1.RELEASE]at com.jd.blockchain.sdk.service.NodeSigningAppender.process(NodeSigningAppender.java:84) ~[sdk-base-1.1.1.RELEASE.jar!/:1.1.1.RELEASE]at com.jd.blockchain.sdk.service.PeerServiceProxy.process(PeerServiceProxy.java:89) ~[sdk-base-1.1.1.RELEASE.jar!/:1.1.1.RELEASE]at com.jd.blockchain.gateway.web.TxProcessingController.process(TxProcessingController.java:70) ~[gateway-1.1.1.RELEASE.jar!/:1.1.1.RELEASE]at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_231]at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_231]at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_231]at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_231]最终查明异常是由于网关里创建AsynchServiceProxy失败导致的，这部分实现采用了Apache-commons-pool2。实现如下：

　　

public class BftsmartPeerProxyFactory extends BasePooledObjectFactory{ private BftsmartClientSettings bftsmartClientSettings; private int gatewayId; private AtomicInteger index = new AtomicInteger(1); public BftsmartPeerProxyFactory(BftsmartClientSettings bftsmartClientSettings, int gatewayId) { this.bftsmartClientSettings = bftsmartClientSettings; this.gatewayId = gatewayId; } @Override public AsynchServiceProxy create() throws Exception { BftsmartTopology topology = BinarySerializeUtils.deserialize(bftsmartClientSettings.getTopology()); MemoryBasedViewStorage viewStorage = new MemoryBasedViewStorage(topology.getView()); TOMConfiguration tomConfiguration = BinarySerializeUtils.deserialize(bftsmartClientSettings.getTomConfig()); //every proxy client has unique id; tomConfiguration.setProcessId(gatewayId + index.getAndIncrement()); AsynchServiceProxy peerProxy = new AsynchServiceProxy(tomConfiguration, viewStorage); return peerProxy; } @Override public PooledObjectwrap(AsynchServiceProxy asynchServiceProxy) { return new DefaultPooledObject<>(asynchServiceProxy); }}

这个代码BinarySerializeUtils.deserialize(bftsmartClientSettings.getTopology())返回的是null，没有正确拿到Bftsmart的网络拓扑。进而查看peer节点，发现只有节点0成功了，其他都抛如下异常，初步判断bftsmart的副本服务因为端口占用启动失败了：

 

　　

11:36:48.479 ERROR bftsmart.tom.ServiceReplica 247 init - null java.net.BindException: 地址已在使用at sun.nio.ch.Net.bind0(Native Method) ~[?:1.8.0_231]at sun.nio.ch.Net.bind(Net.java:433) ~[?:1.8.0_231]at sun.nio.ch.Net.bind(Net.java:425) ~[?:1.8.0_231]at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223) ~[?:1.8.0_231]at io.netty.channel.socket.nio.NioServerSocketChannel.doBind(NioServerSocketChannel.java:130) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:558) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1358) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:501) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.channel.AbstractChannelHandlerContext.bind(AbstractChannelHandlerContext.java:486) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.channel.DefaultChannelPipeline.bind(DefaultChannelPipeline.java:1019) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.channel.AbstractChannel.bind(AbstractChannel.java:254) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.bootstrap.AbstractBootstrap$2.run(AbstractBootstrap.java:366) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:446) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-all-4.1.29.Final.jar:4.1.29.Final]at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231]

从bftsmart官方文档得知，如果在同一个主机运行，不能使用顺序的端口号，即一开始编排的peer的共识端口，6000、6001、6002、6003是不行的，原因如下：如果在同一台计算机（127.0.0.1）中部署/执行了某些（或全部）副本，config/hosts.config则不能具有顺序的端口号（例如10000、10001、10002、10003）。这是因为每个副本都绑定了两个端口：一个用于接收来自客户端的消息，另一个用于接收来自其他副本的消息（通过获取下一个端口号选择） 。更一般而言，如果为副本R分配了端口号P，它将尝试将端口P（绑定到接收到的客户端请求）和端口P + 1（绑定到其他副本）进行绑定。如果不执行此准则，则副本可能无法绑定所有需要的端口。

 

　　文档地址：https://github.com/bft-smart/...

 

　　

结语

jdchain是完整采用java实现的区块链项目，是java开发者研究区块链的一大福音，而且项目开源后一直在迭代，文档和社区支持方面都比较友好。入门虽然很简单，但是要深入到这个项目后面还有很多的东西要研究。楼主计划，后面先把SDK和网关的交互搞清楚，然后在研究下最新的共识实现（基于RabbitMQ），然后在研究下智能合约的应用，最后深入代码实现，可能后面还会有其他的关于jdchain的内容输出。最后希望全部掌握后能给社区贡献点代码、提供点案例、解答点问题。为开源尽自己的绵薄之力

 

　　以上就是java开源区块链jdchain入门的详细内容，更多关于java开源区块链jdchain的资料请关注盛行IT其它相关文章！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

标签：

相关文章阅读

  • java Springboot集成mybatis-plus的方法是什么
  • 浅谈几种Java自定义异常处理方式
  • Java Map所有的值转为String类型
  • java代码中格式化金额 java格式化小数
  • java计算器源代码资源 java计算器简单代码
  • 【java】（一）SpringBoot 源码解析——SpringApplication 初始化（）
  • Spring学习笔记（spring教程 csdn）
  • HDFS Architecture Guide（）
  • 哈工大软件构造Lab3（2022）（哈工大软件构造lab3）
  • nginx基础（nginx基础教程）
  • Java 中HashMap详解(含HashTable, ConcurrentHashMap)（java hashmap使用方法）
  • Java 线程池之Jetty 线程池学习总结（java线程池的使用方法）
  • java线程基础（java 线程教程）
  • 聊聊 Netty 那些事儿之 Reactor 在 Netty 中的实现(创建篇)（）
  • nginx（nginx负载均衡）
    • 留言与评论（共有 条评论）
       
    验证码：