P Peer pvO~Os܂傤B W͂1sƒbZ[W翌Aフとにけ燦oヘに出vOナ MulticasterフアhX"localhost:16534"フ写echo"ƂăvO ܂B16534Ƃ̂ Oni ̃ftHgTCP/IP̃|[głB

import oni.net.*;
import java.io.*;

public class EchoClient {
    public static void main(String[] args) throws NetException, IOException {
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
        LaneAddress address = new LaneAddress("localhost:16534", "echo");
        Peer peer = new Peer(PeerType.SEND_RECEIVE);
        peer.open(address);
        try {
            for (String input = reader.readLine(); input != null; input = reader.readLine()) {
                LaneData sendMessage = new StringLaneData(input);
                peer.send(sendMessage);
                LaneData receiveMessage = peer.receive();
                System.out.println(new StringLaneData(receiveMessage).toString());
            }
        } finally {
            peer.close();
        }
    }
}

ŏ̍sŕW͂͂薰ッ朱た゜BufferedReader 쐬Ă܂B Peer 쐬A"localhost:16534" ̎ʖ "echo" ɂ Multicaster ɐڑĂ܂B ܂AMulticaster ̂肩w LaneAddress 쐬A č쐬 Peer ɑ΂ open \bh ĂяoƂŐڑs܂B

        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
        LaneAddress address = new LaneAddress("localhost:16534", "echo");
        Peer peer = new Peer(PeerType.SEND_RECEIVE);
        peer.open(address);

Peer close \bhĂԂƂŐؒf܂B ł͍ŌɌĂł܂B

            peer.close();

[vł1sǂݍ݁AMulticasterɑ܂B ̂ƁAMulticaster ̂\܂B Mł StringLaneData IuWFNggp܂B LaneData IuWFNg̓tB^O邱ƂŁA܂܂Ȍ`ɕϊł܂B

            for (String input = reader.readLine(); input != null; input = reader.readLine()) {
                LaneData sendMessage = new StringLaneData(input);
                peer.send(sendMessage);
                LaneData receiveMessage = peer.receive();
                System.out.println(new StringLaneData(receiveMessage).toString());
            }

Peer gvO~O̗͈ȉ̂悤ɂȂ܂B

1. Peer ̍쐬Ɛڑ
2. LaneData ̑M
3. Peer ̐ؒf

LaneData ̑M͒ʏ}`Xbhōs܂B Peer ̓}`Xbh̑Mɑ΂ăXbhZ[tɂȂ悤 Ă܂B

Copyright © 2001-2002 CyberStep, Inc. All Rights Reserved.

Oni \tgEFA