rangeconnectionserver.java

来自「the source code of voyager examples---co」· Java 代码 · 共 41 行

// (c) Copyright 2003 Recursion Software, Inc.

package examples.connectionmgmt;

import examples.stockmarket.*;

import com.recursionsw.lib.util.Console;
import com.recursionsw.lib.util.HostAddressRange;
import com.recursionsw.ve.*;
import com.recursionsw.ve.transport.*;
import com.recursionsw.ve.tcp.*;

public class RangeConnectionServer {
    public static void main(String[] args) {
        try {
            Voyager.startup("9000");
            Console.setLogLevel(Console.DEBUG);
            RangeTcpPolicy rangePolicy = new RangeTcpPolicy();
            // Associate a CasePolicy with a HostAddressRange to create a
            // connection policy as follows: unlimited open client connects, max of 3
            // open server connects, unlimited idle connects, unlimited client connect idle time,
            // ten second server connect idle time.
            int NO_LIMIT = CasePolicy.NO_LIMIT;
            rangePolicy.setCasePolicy(
                new HostAddressRange("*:9000"),
                new CasePolicy(NO_LIMIT, 3, NO_LIMIT, 0, 3000));
            Transport.registerConnectionManagementPolicy(
                "tcp",
                new RangeConnectionManagementPolicy(rangePolicy));
            // Add a listener to watch for open/close connection
            Transport.addEventListener(new ConnectionListener());
            IStockmarket market =
                (IStockmarket) Proxy.export(new DelayedStockmarket(), "9000");
            // bind "NASDAQ" to the stockmarket
            Namespace.bind("9000/NASDAQ", market);
        } catch (Exception exception) {
            System.err.println(exception);
        }
    }
}