// log test  
logBuffer.setLength(0);  
try {  
    ECKeyPair ecKeyPair1 = Keys.createEcKeyPair();  
    ECKeyPair ecKeyPair2 = Keys.createEcKeyPair();  
    String address1 = Keys.getAddress(ecKeyPair1);  
    String address2 = Keys.getAddress(ecKeyPair2);  
    logBuffer.append("address1=").append(address1);  
    logBuffer.append("\n(1) pri=").append(ecKeyPair1.getPrivateKey().toString(16));  
    logBuffer.append("\n(1) pub=").append(ecKeyPair1.getPublicKey().toString(16));  
    logBuffer.append("\naddress2=").append(address2);  
    logBuffer.append("\n(2) pri=").append(ecKeyPair2.getPrivateKey().toString(16));  
    logBuffer.append("\n(2) pub=").append(ecKeyPair2.getPublicKey().toString(16));  
} catch (Exception e) {  
    e.printStackTrace();  
    logBuffer.append("生成地址error:").append(e);  
}  
Log.i("test", logBuffer.toString());  
showDialogMsg(logBuffer.toString());  

import java.math.BigInteger;  
  
import rx.Observable;  
  
/**  
 * 根据myetherwallet.com定义的api接口定义  
 * 用来实现以太坊的交易以及合同的发布时的网络接口  
 */  
public interface EtherNode {  
    /**  
     * 获取ChainId，用于EIP155签名时用  
     * @return chainId  
     */  
    int getChainId();  
    /**  
     * // Request  
     * curl -X POST --data '{"jsonrpc":"2.0","method":"eth_blockNumber","params":[],"id":83}'  
     *  
     * // Result  
     * {  
     * "id":83,  
     * "jsonrpc": "2.0",  
     * "result": "0x4b7" // 1207  
     * }  
     *  
     * Returns the number of most recent block.  
     * @return QUANTITY - integer of the current block number the client is on.  
     */  
    Observable<BigInteger> getCurrentBlock();  
  
    /**  
     * // Request  
     * curl -X POST --data '{"jsonrpc":"2.0","method":"eth_getBalance","params":["0x407d73d8a49eeb85d32cf465507dd71d507100c1", "latest"],"id":1}'  
     *  
     * // Result  
     * {  
     * "id":1,  
     * "jsonrpc": "2.0",  
     * "result": "0x0234c8a3397aab58" // 158972490234375000  
     * }  
     *  
     * Returns the balance of the account of given address.  
     * @param address  20 Bytes - address to check for balance.  
     * @return latest balance  
     */  
    Observable<BigInteger> getBalance(String address);  
  
    /**  
     * // Request  
     * curl -X POST --data '{"jsonrpc":"2.0","method":"eth_getTransactionByHash","params":["0xb903239f8543d04b5dc1ba6579132b143087c68db1b2168786408fcbce568238"],"id":1}'  
     *  
     * // Result  
     * {  
     * "id":1,  
     * "jsonrpc":"2.0",  
     * "result": {  
     * "hash":"0xc6ef2fc5426d6ad6fd9e2a26abeab0aa2411b7ab17f30a99d3cb96aed1d1055b",  
     * "nonce":"0x",  
     * "blockHash": "0xbeab0aa2411b7ab17f30a99d3cb9c6ef2fc5426d6ad6fd9e2a26a6aed1d1055b",  
     * "blockNumber": "0x15df", // 5599  
     * "transactionIndex":  "0x1", // 1  
     * "from":"0x407d73d8a49eeb85d32cf465507dd71d507100c1",  
     * "to":"0x85h43d8a49eeb85d32cf465507dd71d507100c1",  
     * "value":"0x7f110", // 520464  
     * "gas": "0x7f110", // 520464  
     * "gasPrice":"0x09184e72a000",  
     * "input":"0x603880600c6000396000f300603880600c6000396000f3603880600c6000396000f360",  
     * }  
     * }  
     *  
     * Returns the information about a transaction requested by transaction hash.  
     *  
     * @param transactionHash 32 Bytes - hash of a transaction  
     * @return  
     */  
    Observable<org.web3j.protocol.core.methods.response.Transaction> getTransaction(String transactionHash);  
  
    class TransactionData {  
        private String address;  
        private BigInteger balance;  
        private BigInteger gasPrice;  
        private BigInteger nonce;  
  
        public TransactionData() {}  
  
        public TransactionData(String address, BigInteger balance, BigInteger gasPrice, BigInteger nonce) {  
            this.address = address;  
            this.balance = balance;  
            this.gasPrice = gasPrice;  
            this.nonce = nonce;  
        }  
  
        public String getAddress() {  
            return address;  
        }  
  
        public BigInteger getBalance() {  
            return balance;  
        }  
  
        public BigInteger getGasPrice() {  
            return gasPrice;  
        }  
  
        public BigInteger getNonce() {  
            return nonce;  
        }  
  
        @Override  
        public String toString() {  
            return "TransactionData{" +  
                    "address='" + address + '\'' +  
                    ", balance=" + balance +  
                    ", gasPrice=" + gasPrice +  
                    ", nonce=" + nonce +  
                    '}';  
        }  
    }  
  
    /**  
     * 根据MyEtherWallet网站的接口定义，返回一个地址的余额、gasPrice、nonce，看用法应该是用来生成新的交易的时候用的  
     * 可以分别调用eth_getBalance获取余额，调用eth_gasPrice获取gasPrice，调用eth_getTransactionCount获取nonce  
     *  
     * @param address 20 Bytes - address to check for balance.  
     * @return  
     */  
    Observable<TransactionData> getTransactionData(String address);  
  
    /**  
     * // Request  
     * curl -X POST --data '{"jsonrpc":"2.0","method":"eth_sendRawTransaction","params":[{see above}],"id":1}'  
     *  
     * // Result  
     * {  
     * "id":1,  
     * "jsonrpc": "2.0",  
     * "result": "0xe670ec64341771606e55d6b4ca35a1a6b75ee3d5145a99d05921026d1527331"  
     * }  
     *  
     * Creates new message call transaction or a contract creation for signed transactions.  
     * @param signedTransactionData  
     * @return 交易的hash值  
     */  
    Observable<String> sendRawTransaction(String signedTransactionData);  
  
    /**  
     * // Request  
     * curl -X POST --data '{"jsonrpc":"2.0","method":"eth_estimateGas","params":[{see above}],"id":1}'  
     *  
     * // Result  
     * {  
     * "id":1,  
     * "jsonrpc": "2.0",  
     * "result": "0x5208" // 21000  
     * }  
     *  
     * Generates and returns an estimate of how much gas is necessary to allow the transaction to complete.  
     * The transaction will not be added to the blockchain.  
     * Note that the estimate may be significantly more than the amount of gas actually used by the transaction,  
     * for a variety of reasons including EVM mechanics and node performance.  
     *  
     * @param transaction  
     * @return the amount of gas used.  
     */  
    Observable<BigInteger> getEstimatedGas(org.web3j.protocol.core.methods.request.Transaction transaction);  
  
    /**  
     *  
     * // Request  
     * curl -X POST --data '{"jsonrpc":"2.0","method":"eth_call","params":[{see above}],"id":1}'  
     *  
     * // Result  
     * {  
     * "id":1,  
     * "jsonrpc": "2.0",  
     * "result": "0x"  
     * }  
     *  
     * Executes a new message call immediately without creating a transaction on the block chain.  
     * param use 'pending'  
     * see <a href='https://github.com/ethereum/wiki/wiki/JSON-RPC#eth_call'>https://github.com/ethereum/wiki/wiki/JSON-RPC#eth_call</a>  
     * @param transaction The transaction call object  
     * @return the return value of executed contract.  
     */  
    Observable<String> getEthCall(org.web3j.protocol.core.methods.request.Transaction transaction);  
}  

import android.util.Log;  
  
import com.hengbao.hdwallet.network.ether.EtherNode;  
  
import org.web3j.protocol.Web3j;  
import org.web3j.protocol.Web3jFactory;  
import org.web3j.protocol.core.DefaultBlockParameterName;  
import org.web3j.protocol.core.methods.response.EthBlock;  
import org.web3j.protocol.core.methods.response.EthCall;  
import org.web3j.protocol.core.methods.response.EthEstimateGas;  
import org.web3j.protocol.core.methods.response.EthGasPrice;  
import org.web3j.protocol.core.methods.response.EthGetBalance;  
import org.web3j.protocol.core.methods.response.EthGetTransactionCount;  
import org.web3j.protocol.core.methods.response.EthSendTransaction;  
import org.web3j.protocol.core.methods.response.EthTransaction;  
import org.web3j.protocol.core.methods.response.Transaction;  
import org.web3j.protocol.http.HttpService;  
  
import java.math.BigInteger;  
  
import okhttp3.OkHttpClient;  
import okhttp3.logging.HttpLoggingInterceptor;  
import rx.Observable;  
import rx.exceptions.Exceptions;  
import rx.functions.Func1;  
import rx.functions.Func3;  
  
/**  
 * 符合web3j的JSON-RPC接口的节点实现  
 */  
public class CustomNodeImpl implements EtherNode {  
    /**  
     * chainId,see {@link org.web3j.tx.ChainId}  
     */  
    private int chainId;  
    /**  
     * 服务器的url，ex：http://localhost:8545/  
     */  
    private String url;  
    private Web3j web3j;  
  
    /**  
     * 构造  
     * @param url 服务器的url，ex：http://localhost:8545/  
     * @param chainId chainId,see {@link org.web3j.tx.ChainId}  
     */  
    public CustomNodeImpl(String url, int chainId) {  
        this.url = url;  
        this.chainId = chainId;  
  
        OkHttpClient.Builder builder = new OkHttpClient.Builder();  
        HttpLoggingInterceptor logging = new HttpLoggingInterceptor(  
                new HttpLoggingInterceptor.Logger() {  
                    @Override  
                    public void log(String msg) {  
                        Log.i("http", msg);  
                    }  
                });  
        logging.setLevel(HttpLoggingInterceptor.Level.BODY);  
        builder.addInterceptor(logging);  
  
        this.web3j = Web3jFactory.build(new HttpService(url, builder.build(), true));  
    }  
  
    @Override  
    public Observable<BigInteger> getCurrentBlock() {  
        return web3j.ethGetBlockByNumber(DefaultBlockParameterName.LATEST, true)  
                .observable()  
                .map(new Func1<EthBlock, BigInteger>() {  
                    @Override  
                    public BigInteger call(EthBlock ethBlock) {  
                        if(ethBlock.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethBlock.getError()));  
                        } else {  
                            return ethBlock.getBlock().getNumber();  
                        }  
                    }  
                });  
    }  
  
    @Override  
    public Observable<BigInteger> getBalance(String address) {  
        return web3j.ethGetBalance(address, DefaultBlockParameterName.LATEST)  
                .observable()  
                .map(new Func1<EthGetBalance, BigInteger>() {  
                    @Override  
                    public BigInteger call(EthGetBalance ethGetBalance) {  
                        if(ethGetBalance.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethGetBalance.getError()));  
                        } else {  
                            return ethGetBalance.getBalance();  
                        }  
                    }  
                });  
    }  
  
    @Override  
    public Observable<Transaction> getTransaction(String transactionHash) {  
        return web3j.ethGetTransactionByHash(transactionHash)  
                .observable()  
                .map(new Func1<EthTransaction, Transaction>() {  
                    @Override  
                    public Transaction call(EthTransaction ethTransaction) {  
                        if(ethTransaction.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethTransaction.getError()));  
                        } else {  
                            return ethTransaction.getTransaction();  
                        }  
                    }  
                });  
    }  
  
    @Override  
    public Observable<TransactionData> getTransactionData(final String address) {  
        Observable<BigInteger> balanceObservable = web3j.ethGetBalance(address, DefaultBlockParameterName.PENDING)  
                .observable()  
                .map(new Func1<EthGetBalance, BigInteger>() {  
                    @Override  
                    public BigInteger call(EthGetBalance ethGetBalance) {  
                        if(ethGetBalance.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethGetBalance.getError()));  
                        } else {  
                            return ethGetBalance.getBalance();  
                        }  
                    }  
                });  
        Observable<BigInteger> gasPriceObservable = web3j.ethGasPrice()  
                .observable()  
                .map(new Func1<EthGasPrice, BigInteger>() {  
                    @Override  
                    public BigInteger call(EthGasPrice ethGasPrice) {  
                        if(ethGasPrice.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethGasPrice.getError()));  
                        } else {  
                            return ethGasPrice.getGasPrice();  
                        }  
                    }  
                });  
        Observable<BigInteger> nonceObservable = web3j.ethGetTransactionCount(address, DefaultBlockParameterName.PENDING)  
                .observable()  
                .map(new Func1<EthGetTransactionCount, BigInteger>() {  
                    @Override  
                    public BigInteger call(EthGetTransactionCount ethGetTransactionCount) {  
                        if(ethGetTransactionCount.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethGetTransactionCount.getError()));  
                        } else {  
                            return ethGetTransactionCount.getTransactionCount();  
                        }  
                    }  
                });  
        return Observable.zip(balanceObservable, gasPriceObservable, nonceObservable,  
                new Func3<BigInteger, BigInteger, BigInteger, TransactionData>() {  
                    @Override  
                    public TransactionData call(BigInteger balance, BigInteger gasPrice, BigInteger nonce) {  
                        return new TransactionData(address, balance, gasPrice, nonce);  
                    }  
                });  
    }  
  
    @Override  
    public Observable<String> sendRawTransaction(String signedTransactionData) {  
        return web3j.ethSendRawTransaction(signedTransactionData)  
                .observable()  
                .map(new Func1<EthSendTransaction, String>() {  
                    @Override  
                    public String call(EthSendTransaction ethSendTransaction) {  
                        if(ethSendTransaction.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethSendTransaction.getError()));  
                        } else {  
                            return ethSendTransaction.getTransactionHash();  
                        }  
                    }  
                });  
    }  
  
    @Override  
    public Observable<BigInteger> getEstimatedGas(org.web3j.protocol.core.methods.request.Transaction transaction) {  
        return web3j.ethEstimateGas(transaction)  
                .observable()  
                .map(new Func1<EthEstimateGas, BigInteger>() {  
                    @Override  
                    public BigInteger call(EthEstimateGas ethEstimateGas) {  
                        if(ethEstimateGas.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethEstimateGas.getError()));  
                        } else {  
                            return ethEstimateGas.getAmountUsed();  
                        }  
                    }  
                });  
    }  
  
    @Override  
    public Observable<String> getEthCall(org.web3j.protocol.core.methods.request.Transaction transaction) {  
        return web3j.ethCall(transaction, DefaultBlockParameterName.PENDING)  
                .observable()  
                .map(new Func1<EthCall, String>() {  
                    @Override  
                    public String call(EthCall ethCall) {  
                        if(ethCall.hasError()) {  
                            throw Exceptions.propagate(JsonRpcException.crate(ethCall.getError()));  
                        } else {  
                            return ethCall.getValue();  
                        }  
                    }  
                });  
    }  
  
    @Override  
    public int getChainId() {  
        return chainId;  
    }  
  
    public String getUrl() {  
        return url;  
    }  
}  

final String address1 = "0x5378ad743b9263587eb117b0c4658cf03c906baa";  
...省略部分代码...  
etherNode.getBalance(address1)  
        .subscribeOn(Schedulers.newThread())  
        .observeOn(AndroidSchedulers.mainThread())  
        .subscribe(new Action1<BigInteger>() {  
            @Override  
            public void call(BigInteger bigInteger) {  
                showDialogMsg(String.format("地址%s的余额为:%s(wei)", address1, bigInteger.toString()));  
            }  
        }, new Action1<Throwable>() {  
            @Override  
            public void call(Throwable throwable) {  
                throwable.printStackTrace();  
                showDialogMsg("查询余额失败:" + throwable);  
            }  
        });  

final String address2 = "0x370dccebbf4d24059ae57fddbb651259a86a172a";  
...省略部分代码...  
etherNode.getBalance(address2)  
        .subscribeOn(Schedulers.newThread())  
        .observeOn(AndroidSchedulers.mainThread())  
        .subscribe(new Action1<BigInteger>() {  
            @Override  
            public void call(BigInteger bigInteger) {  
                showDialogMsg(String.format("地址%s的余额为:%s(wei)", address2, bigInteger.toString()));  
            }  
        }, new Action1<Throwable>() {  
            @Override  
            public void call(Throwable throwable) {  
                throwable.printStackTrace();  
                showDialogMsg("查询余额失败:" + throwable);  
            }  
        });  

// 两个地址的测试数据  
final String address1 = "0x5378ad743b9263587eb117b0c4658cf03c906baa";  
final ECKeyPair ecKeyPair1 = new ECKeyPair(  
        new BigInteger("d36d0bb6c8f2ec5e3ea59b0b8a17fd78e2091c9e77d2a70267c01cf10a38fc48", 16),  
        new BigInteger("34a1d310e41a8b4de639ff48d8edea8702c654207fe93783cede051f261e42e8e33d5180bdd176b45d9dd97120b7b882bd9450322fb9b04ef31cb285a72f347c", 16));  
  
final String address2 = "0x370dccebbf4d24059ae57fddbb651259a86a172a";  
final ECKeyPair ecKeyPair2 = new ECKeyPair(  
        new BigInteger("d90b9e5b063cd5d8e56c536c341260048f563c5e8740e071145e72e4208bf883", 16),  
        new BigInteger("ece19a85208e5198a412ab2710a992356d837726db7e06d745d31d667339e923e92409c00d17b969545a2557b8cd3869e4fa4d90c3ca23d58c693c34247a1dab", 16));  
  
...省略部分代码...  
  
// 清空log buffer  
logBuffer.setLength(0);  
  
final BigInteger amount = new BigInteger("9000");  
Observable<BigInteger> currBlockObs = etherNode.getCurrentBlock();  
org.web3j.protocol.core.methods.request.Transaction estimatedGasTran =  
        new org.web3j.protocol.core.methods.request.Transaction(  
                address1,  
                null, // nonce  
                new BigInteger("051da038cc", 16), // gasPrice  
                new BigInteger("ffffff", 16), // gasLimit  
                address2, // to  
                amount, // value  
                null);  
Observable<BigInteger> estimatedGasObs = etherNode.getEstimatedGas(estimatedGasTran);  
Observable<EtherNode.TransactionData> transactionDataObs = etherNode.getTransactionData(address1);  
  
Observable.zip(currBlockObs, estimatedGasObs, transactionDataObs, new Func3<BigInteger ,BigInteger, EtherNode.TransactionData, RawTransaction>() {  
    @Override  
    public RawTransaction call(BigInteger currBlock, BigInteger gas_limit, EtherNode.TransactionData transactionData) {  
        // test log  
        logBuffer.append("\n获取到的currBlock=").append(currBlock);  
        logBuffer.append("\n获取到的gas_limit=").append(gas_limit);  
        logBuffer.append("\n获取到的transactionData=").append(transactionData);  
  
        // test log  
        logBuffer.append("\n组交易之前：\nnonce=").append(transactionData.getNonce().toString(16))  
                .append("\ngasPrice=").append(transactionData.getGasPrice().toString(16))  
                .append("\ngasLimit=").append(gas_limit.toString(16))  
                .append("\ntoAddress=").append(address2)  
                .append("\namount=").append(amount.toString(16))  
                .append("\ndata=null");  
  
        // 需要为每个交易  
  
        RawTransaction tx = RawTransaction.createTransaction(  
                transactionData.getNonce(),  
                transactionData.getGasPrice(),  
                gas_limit,  
                address2,  
                amount,  
                ""  
        );  
        return tx;  
    }  
}).map(new Func1<RawTransaction, String>() {  
    @Override  
    public String call(RawTransaction rawTransaction) {  
        // TODO 直接使用EIP155的规范进行签名，会不会出现问题?  
        Credentials keys = Credentials.create(ecKeyPair1);  
        byte[] signed = TransactionEncoder.signMessage(rawTransaction, (byte) etherNode.getChainId(), keys);  
        String signTx = ByteUtils.toHexString(signed);  
        logBuffer.append("\n签名以后的数据为：").append(signTx);  
        return signTx;  
    }  
}).flatMap(new Func1<String, Observable<String>>() {  
    @Override  
    public Observable<String> call(String tx) {  
        logBuffer.append("\n调用发布交易接口...");  
        if(tx != null && !tx.startsWith("0x") && !tx.startsWith("0X")) {  
            tx = "0x" + tx;  
        }  
        return etherNode.sendRawTransaction(tx);  
    }  
}).subscribeOn(Schedulers.newThread())  
.observeOn(AndroidSchedulers.mainThread())  
.subscribe(new Action1<String>() {  
    @Override  
    public void call(String s) {  
        logBuffer.append("\n交易发布成功,hash为：").append(s);  
  
        showDialogMsg(logBuffer.toString());  
        Log.i("test", logBuffer.toString());  
    }  
}, new Action1<Throwable>() {  
    @Override  
    public void call(Throwable throwable) {  
        throwable.printStackTrace();  
        logBuffer.append("\n交易发布失败,throwable=").append(throwable);  
        showDialogMsg(logBuffer.toString());  
        Log.i("test", logBuffer.toString());  
    }  
});