gistfile1.java

    public static void main(String[] args) {
        //  リピータハブとして動作
        MessageListener hub = new MessageListener() {
            public void messageReceived(Channel channel, OFMessage msg) {
                if (msg.getType() == OFType.PACKET_IN) {
                    OFPacketIn in = (OFPacketIn)msg;
                    OFPacketOut out = (OFPacketOut)factory.getMessage(OFType.PACKET_OUT);
                    out.setBufferId(in.getBufferId());
                    out.setInPort(in.getInPort());

                    //  フラッディングで出力
                    OFActionOutput action = new OFActionOutput();
                    action.setPort(OFPort.OFPP_FLOOD.getValue());
                    out.setActions(Collections.singletonList((OFAction)action));
                    out.setActionsLength((short)OFActionOutput.MINIMUM_LENGTH);

                    //  PACKET_INで受信したパケットの内容を出力パケットに設定
                    if (in.getBufferId() == 0xffffffff) {
                        byte[] packetData = in.getPacketData();
                        out.setLength((short)(OFPacketOut.MINIMUM_LENGTH + out.getActionsLength() + packetData.length));
                        out.setPacketData(packetData);
                    //  バッファリングされている場合には、パケットの内容を設定しなくてもよい
                    } else {
                        out.setLength((short)(OFPacketOut.MINIMUM_LENGTH + out.getActionsLength()));
                    }

                    channel.write(out);
                    log.debug("Message sent: message({}), switch({})", out.getType(), channel.getRemoteAddress());
                }
            }
        };

        SimpleController controller = new SimpleController();
        controller.addMessageListener(hub);

        //  引数が与えられた場合は、指定されたポート番号を使用
        int port = CONTROLLER_DEFAULT_PORT;
        if (args.length >= 1) {
            port = Integer.parseInt(args[0]);
        }
        controller.start(port);
    }