Hola amigos, hoy les quiero hablar de la librer\u00eda Web3j en la cual he hecho varias pruebas y me parece genial ya que es muy ligera y contiene todo lo necesario para crear aplicaci\u00f3n y contratos inteligentes en la blockchain de ethereum.<\/p>\n
Es una biblioteca ligera escrita en Java 8, esta en una capa superior ya que necesita integrarse con un cliente o nodo de la red Ethereum, en mi entrada anterior\u00a0Instalar un nodo testnet de ethereum rinkeby<\/a> esta todo lo necesario para crear tu propio nodo y obtener monedas testnet para comenzar las pruebas.<\/p>\n <\/p>\n Si necesitas m\u00e1s informaci\u00f3n acerca de este proyecto te dejo unos enlaces de la documentaci\u00f3n oficial:<\/p>\n Lo primero que vamos a hacer es crear una cuenta ethereum para recibir nuestro ether, para ello vamos a utilizar el api de web3j<\/p>\n En la sentencia anterior podemos destacar la siguiente linea:\u00a0WalletUtils.generateFullNewWalletFile(password, file);\u00a0<\/strong>Como podemos ver hemos usando la clase WalletUtils y hemos creado una cuenta ethereum de una forma muy simple.<\/p>\n Invocamos nuestro m\u00e9todo de la forma siguiente:<\/p>\n El arreglo generado contiene las siguientes cadenas:<\/p>\n 1.- Nombre del monedero:<\/p>\n 2.- JSON con los datos del monedero:<\/p>\n Las cuentas en ethereum son ficheros JSON encriptados con una contrase\u00f1a. Este fichero debe guardarse con mucho cuidado y en un lugar seguro ya que podrias perder tus ether.<\/p>\n Ahora queremos comenzar a utilizar nuestra cuenta ethereum para ello vamos a ver el siguiente m\u00e9todo:<\/p>\n Hemos usado nuevamente la clase\u00a0WalletUtils, esta vez el m\u00e9todo\u00a0loadCredentials que necesita el nombre de la cuenta ethereum y la contrase\u00f1a. Este nos retorna un objeto Credencial el cual nos da acceso a administrar nuestros ether de ese monedero.<\/p>\n Este seria un ejemplo para utilizar el m\u00e9todo anterior:<\/p>\n Para comenzar a usar los m\u00e9todos de webj3 necesitamos conectarnos al nodo que tenemos en ejecuci\u00f3n, recordando mi post anterior <\/a>hemos colocado el socket IPC en la siguiente ruta \u00ab\/opt\/apps\/geth.ipc\u00bb, ahora bien si queremos conectarnos directamente al socket y tener los eventos de la blockchain en tiempo real usaremos:<\/p>\n O bien si no queremos usar Socket podemos usar HTTP con las siguiente sentencia:<\/p>\n Ahora si a todos se nos viene la primera pregunta y \u00bfComo vemos el saldo de nuestro monedero? Vamos a crear el siguiente m\u00e9todo que nos retorna el saldo del monedero.<\/p>\n Ya estamos utilizando el objecto web3j en esta caso hemos usado\u00a0web3j .ethGetBalance el cual en realidad hace un llamado al Api de Ethereum como se ve a continuaci\u00f3n:<\/p>\n Vamos a ver un ejemplo del uso del m\u00e9todo que hemos creado:<\/p>\n Para recibir ether tenemos los m\u00e9todos\u00a0Observable que implementa Java RX para el manejo de eventos, vamos a crear el siguiente m\u00e9todo:<\/p>\n Creamos el objecto Subscription para ver los eventos de web3j con:<\/p>\n Ahora si recarguemos nuestro monedero en nuestro caso he enviado 0.03 ether desde la linea de comando de geth, en la cual tenemos saldo:<\/p>\n y lo hemos recibido en nuestro monedero :<\/p>\n Ahora ya que ya tenemos balance en nuestra cuenta podemos enviar ethers usando el siguiente m\u00e9todo:<\/p>\n Ahora vamos a enviar ether usando el m\u00e9todo creado<\/p>\n Y vemos como se dispara el evento en nuestra billetera.<\/p>\n Ahora quiero listar todas las entradas y salidas de mi cuenta, de momento no he podido hacerlo con el api de web3j \u00a0y al parecer es un poco mas complejo ya que tendr\u00edamos que desarrollar un script en la consola de geth. Por ahora vamos a usar el API de ETHERSCAN<\/a><\/p>\n Probamos el m\u00e9todo con la siguiente sentencia de c\u00f3digo:<\/p>\nCaracter\u00edsticas principales:<\/h3>\n
\n
Enlaces de inter\u00e9s:<\/h3>\n
\n
Creando una cuenta Ethereum en Java usando Web3j<\/h3>\n
public static String[] createNewWallet(String password) throws Exception {\r\n try {\r\n File file = new File(WALLET_PATH);\r\n String name = null;\r\n String json = null;\r\n if (file.exists()) {\r\n \/\/ al crear el monedero nos retorna el nombre del archivo generado dentro de la carpeta indicada\r\n name = WalletUtils.generateFullNewWalletFile(password, file);\r\n \/\/ vamos a abrir el monedero y retornar el json generado\r\n Path path = FileSystems.getDefault().getPath(WALLET_PATH, name);\r\n byte[] b = java.nio.file.Files.readAllBytes(path);\r\n json = new String(b);\r\n return new String[]{name, json};\r\n } else {\r\n throw new Exception(\"Invalid WALLET_PATH \" + WALLET_PATH);\r\n }\r\n\r\n } catch (Exception ex) {\r\n throw ex;\r\n }\r\n }<\/pre>\nEthereumWallet e = EthereumWallet.getInstance();\r\nString[] wallet = e.createNewWallet(\"123456\");\r\nfor (String string : wallet) {\r\n System.out.println(string);\r\n}<\/pre>\nUTC--2017-07-16T16-58-10.930000000Z--54f80f2634207fba30525ebdd779cedd7e745cb4.json<\/pre>\n
{\r\n\t\"address\": \"54f80f2634207fba30525ebdd779cedd7e745cb4\",\r\n\t\"id\": \"c3484c26-54af-4c4f-baf5-a10caf813031\",\r\n\t\"version\": 3,\r\n\t\"crypto\": {\r\n\t\t\"cipher\": \"aes-128-ctr\",\r\n\t\t\"ciphertext\": \"1a70945a3f05a3c2e2bb3def0cd3b88b735462067ebe5acc1f63a74f6b98bb15\",\r\n\t\t\"cipherparams\": {\r\n\t\t\t\"iv\": \"d3d05d62e600f3d1f91f64856db9a8c2\"\r\n\t\t},\r\n\t\t\"kdf\": \"scrypt\",\r\n\t\t\"kdfparams\": {\r\n\t\t\t\"dklen\": 32,\r\n\t\t\t\"n\": 262144,\r\n\t\t\t\"p\": 1,\r\n\t\t\t\"r\": 8,\r\n\t\t\t\"salt\": \"ba10abe0b7adb51bc52dacc477ebeb5e3008d5f72fa60bfee3a6d409483248fd\"\r\n\t\t},\r\n\t\t\"mac\": \"96ae81b9a7233c544cca25616f0b85adad7b9ec9b1e5a2e81dc686d7e4576086\"\r\n\t}\r\n}<\/pre>\nAbrir una cuenta Ethereum en Java usando Web3j<\/h3>\n
public Credentials openWallet(String password, String walletName) throws Exception {\r\n Credentials credentials = WalletUtils.loadCredentials(password, WALLET_PATH + walletName);\r\n return credentials;\r\n}<\/pre>\nCredentials credentials = e.openWallet(\"123456\", \"UTC--2017-07-16T16-58-10.930000000Z--54f80f2634207fba30525ebdd779cedd7e745cb4.json\");\r\nString addressSender = credentials.getAddress();\r\nSystem.out.println(addressSender);<\/pre>\n
Crear una instancia del objecto\u00a0Web3j<\/h3>\n
private final static String IPC_SOCKET_PATH = \"\/opt\/apps\/geth.ipc\";\r\n\r\nweb3j = Web3j.build(new UnixIpcService(IPC_SOCKET_PATH));<\/pre>\n
private final static String URL_JSON_RPC = \"http:\/\/127.0.0.1:38904\";\r\n\r\nweb3j = Web3j.build(new HttpService(URL_JSON_RPC));<\/pre>\n
Ver el balance o saldo de una cuenta Ethereum en Java usando Web3j<\/h3>\n
public BigInteger getAddressBalance(String address) throws Exception {\r\n try {\r\n \/\/ Vamos a enviar una solicitud as\u00edncrona usando el objecto web3j \r\n EthGetBalance ethGetBalance = web3j\r\n .ethGetBalance(address, DefaultBlockParameterName.LATEST)\r\n .sendAsync()\r\n .get();\r\n \r\n \/\/ saldo en wei\r\n BigInteger wei = ethGetBalance.getBalance();\r\n return wei;\r\n } catch (Exception ex) {\r\n throw ex;\r\n }\r\n }<\/pre>\n{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBalance\",\"params\":[\"0x54f80f2634207fba30525ebdd779cedd7e745cb4\",\"latest\"],\"id\":1}<\/pre>\nBigInteger wei = e.getAddressBalance(addressSender);\r\nSystem.out.println(wei + \" wei\"); \/\/ Salida en wei \r\nBigDecimal x18 = new BigDecimal(\"1000000000000000000\");\r\nBigDecimal bigDecimal = new BigDecimal(wei);\r\nBigDecimal result = bigDecimal.divide(x18);\r\nSystem.out.println(result + \" ether\"); \/\/ salida en ether<\/pre>\n
Recibiendo ether en nuestra cuenta Ethereum usando Web3j:<\/h3>\n
public void onTransactionReceived(Transaction tx) {\r\n BigInteger wei = tx.getValue();\r\n BigDecimal ether = Convert.fromWei(new BigDecimal(tx.getValue()), Convert.Unit.ETHER);\r\n String to = tx.getTo();\r\n String hash = tx.getHash();\r\n String from = tx.getFrom();\r\n\r\n if (addressMap.containsKey(tx.getTo())) {\r\n \/\/ credito\r\n System.out.println(\"Se ha recibido su dep\u00f3sito de \" + ether + \" ether enviado a su cuenta \" + to + \" enviado por \" + from + \" tx \" + hash);\r\n } else if (addressMap.containsKey(tx.getFrom())) {\r\n \/\/debito\r\n System.out.println(\"Se ha hecho un retiro de \" + ether + \" ether desde su cuenta \" + to + \" hacia la cuenta destino \" + from + \" tx \" + hash);\r\n }\r\n }<\/pre>\n subscription = web3j.blockObservable(false).subscribe(block -> {\r\n blockObservable(block);\r\n }, Throwable::printStackTrace, () -> System.out.println(\"block done\"));\r\n web3j.transactionObservable().subscribe(tx -> {\r\n transactionObservable(tx);\r\n }, Throwable::printStackTrace, () -> System.out.println(\"tx done\"));\r\n web3j.pendingTransactionObservable().subscribe(tx -> {\r\n pendingTransactionObservable(tx);\r\n }, Throwable::printStackTrace, () -> System.out.println(\"ptx done\"));<\/pre>\n> eth.accounts[0];\r\n\"0xe2632021f255da92be0c0434855a63acbcbae286\"\r\n> var sender = eth.accounts[0];\r\nundefined\r\n> var receiver = '0x54f80f2634207fba30525ebdd779cedd7e745cb4'\r\nundefined\r\n> var amount = web3.toWei(0.03, \"ether\")\r\nundefined\r\n> personal.unlockAccount(sender, \"123456\")\r\n> eth.sendTransaction({from:sender, to:receiver, value: amount})\r\n\"0xcc6403a6179698a653419cccac7458445ff318482054b6bfb0141e9323c9382e\"\r\n<\/pre>\nSe ha recibido su dep\u00f3sito de 0.03 ether enviado a su cuenta 0x54f80f2634207fba30525ebdd779cedd7e745cb4 enviado por 0xe2632021f255da92be0c0434855a63acbcbae286 tx 0xcc6403a6179698a653419cccac7458445ff318482054b6bfb0141e9323c9382e\r\n<\/pre>\n
Enviar ether desde nuestra cuenta Ethereum usando Web3j:<\/h3>\n
public TransactionReceipt sendCoins(Credentials credentials, String toAddress, BigDecimal value) throws Exception {\r\n try {\r\n TransactionReceipt transactionReceipt = Transfer.sendFunds(web3j, credentials, toAddress, value, Convert.Unit.ETHER);\r\n return transactionReceipt;\r\n } catch (Exception ex) {\r\n throw ex;\r\n }\r\n }<\/pre>\ne.sendCoins(credentials, sendAccount, new BigDecimal(ethers));<\/pre>\n
Se ha hecho un retiro de 0.02 ether desde su cuenta 0xe2632021f255da92be0c0434855a63acbcbae286 hacia la cuenta destino 0x54f80f2634207fba30525ebdd779cedd7e745cb4 tx 0x9b0c842a143678cc7aeca7818ed82ea414727605e409a540bb84d92ca62b36c7\r\n<\/pre>\n
Ver transacciones de mi monedero usando\u00a0ETHERSCAN<\/h3>\n
private final static String ENDPOINT_TRANSACTIONS_LIST = \"\/api?module=account&action=txlist\";\r\nprivate final static String API_RESTFUL_URI = \"http:\/\/rinkeby.etherscan.io\";\r\n\r\n public static Transactions getTransactionsByAddress(String address) {\r\n String endpoint = API_RESTFUL_URI + ENDPOINT_TRANSACTIONS_LIST;\r\n \r\n Client client = ClientBuilder.newClient();\r\n Response response = client.target(endpoint)\r\n .queryParam(\"address\", address)\r\n .queryParam(\"startblock\", \"0\")\r\n .queryParam(\"endblock\", \"99999999\")\r\n .queryParam(\"sort\", \"asc\")\r\n .queryParam(\"apikey\", ETHERSCAN_APIKEY)\r\n .request(MediaType.APPLICATION_JSON)\r\n .get();\r\n \r\n String json = response.readEntity(String.class);\r\n \r\n client.close();\r\n ObjectMapper mapper = new ObjectMapper();\r\n Transactions transactions = null;\r\n if (response.getStatus() == 200) {\r\n try {\r\n transactions = mapper.readValue(json, Transactions.class);\r\n } catch (IOException e) {\r\n e.printStackTrace();\r\n }\r\n }\r\n\r\n return transactions;\r\n }<\/pre>\nTransactions tx = EtherscanService.getTransactionsByAddress(addressSender);\r\nList<Result> list = tx.getResult();\r\nfor (Result result : list) {\r\n System.out.print(\" BlockHash \" + result.getBlockHash());\r\n}<\/pre>\n