import com.google.bitcoin.core.TransactionBroadcaster; //导入依赖的package包/类
/**
 * Sets up a new payment channel server which listens on the given port.
 *
 * @param broadcaster The PeerGroup on which transactions will be broadcast - should have multiple connections.
 * @param wallet The wallet which will be used to complete transactions
 * @param timeoutSeconds The read timeout between messages. This should accommodate latency and client ECDSA
 *                       signature operations.
 * @param minAcceptedChannelSize The minimum amount of coins clients must lock in to create a channel. Clients which
 *                               are unwilling or unable to lock in at least this value will immediately disconnect.
 *                               For this reason, a fairly conservative value (in terms of average value spent on a
 *                               channel) should generally be chosen.
 * @param eventHandlerFactory A factory which generates event handlers which are created for each new connection
 */
public PaymentChannelServerListener(TransactionBroadcaster broadcaster, Wallet wallet,
                                    final int timeoutSeconds, BigInteger minAcceptedChannelSize,
                                    HandlerFactory eventHandlerFactory) throws IOException {
    this.wallet = checkNotNull(wallet);
    this.broadcaster = checkNotNull(broadcaster);
    this.eventHandlerFactory = checkNotNull(eventHandlerFactory);
    this.minAcceptedChannelSize = checkNotNull(minAcceptedChannelSize);

    server = new NioServer(new StreamParserFactory() {
        @Override
        public ProtobufParser getNewParser(InetAddress inetAddress, int port) {
            return new ServerHandler(new InetSocketAddress(inetAddress, port), timeoutSeconds).socketProtobufHandler;
        }
    });
}
 

import com.google.bitcoin.core.TransactionBroadcaster; //导入依赖的package包/类
public static RecordingPair makeRecorders(final Wallet serverWallet, final TransactionBroadcaster mockBroadcaster) {
    RecordingPair pair = new RecordingPair();
    pair.serverRecorder = new RecordingServerConnection();
    pair.server = new PaymentChannelServer(mockBroadcaster, serverWallet, Utils.COIN, pair.serverRecorder);
    pair.clientRecorder = new RecordingClientConnection();
    return pair;
}
 

import com.google.bitcoin.core.TransactionBroadcaster; //导入依赖的package包/类
public void broadcastTransaction(final TransactionBroadcaster broadcaster,
                                 final Transaction tx) {
    new Thread() {
        @Override
        public void run() {
            // Handle the future results just for logging.
            try {
                Futures.addCallback(broadcaster.broadcastTransaction(tx),
                                    new FutureCallback<Transaction>() {
                    @Override
                    public void onSuccess(Transaction transaction) {
                        mLogger.info("Successfully broadcast sweep tx: {}",
                                     transaction);
                    }

                    @Override
                    public void onFailure(Throwable throwable) {
                        mLogger.error("Failed to broadcast sweep tx",
                                      throwable);
                    }
                });
            } catch (Exception e) {
                mLogger.error("Failed to broadcast sweep tx", e);
            }
        }
    }.start();
}
 

import com.google.bitcoin.core.TransactionBroadcaster; //导入依赖的package包/类
/**
 * Sets up a new payment channel server which listens on the given port.
 *
 * @param broadcaster The PeerGroup on which transactions will be broadcast - should have multiple connections.
 * @param wallet The wallet which will be used to complete transactions
 * @param timeoutSeconds The read timeout between messages. This should accommodate latency and client ECDSA
 *                       signature operations.
 * @param minAcceptedChannelSize The minimum amount of coins clients must lock in to create a channel. Clients which
 *                               are unwilling or unable to lock in at least this value will immediately disconnect.
 *                               For this reason, a fairly conservative value (in terms of average value spent on a
 *                               channel) should generally be chosen.
 * @param eventHandlerFactory A factory which generates event handlers which are created for each new connection
 */
public PaymentChannelServerListener(TransactionBroadcaster broadcaster, Wallet wallet,
                                    final int timeoutSeconds, BigInteger minAcceptedChannelSize,
                                    HandlerFactory eventHandlerFactory) throws IOException {
    this.wallet = checkNotNull(wallet);
    this.broadcaster = checkNotNull(broadcaster);
    this.eventHandlerFactory = checkNotNull(eventHandlerFactory);
    this.minAcceptedChannelSize = checkNotNull(minAcceptedChannelSize);
    this.timeoutSeconds = timeoutSeconds;
}