私たちの先生は、クラス MulticastImageSender (MIS) と MulticastImageReceiver (MIR) の 2 つのプログラムを変更するように指示しています。私のアドレスはマルチキャスト アドレスではないと言われ続けます。
MIS の引数: java -jar MIS.jar 127.0.0.0 1234 4 "/home/kevin/Pictures/ME.png" MIR の引数: java -jar MIR.jar 127.0.0.0 1234
次に、最初にレシーバーを実行しますが、これらの出力を取得し続けます
MIS の出力:
Sent /home/kevin/Pictures/ME.png to 127.0.0.0 on port 1234
MIR の出力:
Exception in thread "main" java.lang.IllegalArgumentException: Not a multicast address
at MulticastImageReceiver.main(MulticastImageReceiver.java:35)
これで、マルチキャスト アドレスが 244.xxx で、一部が予約されていることがわかりましたが、ローカル マシン アドレスを使用して自分自身に送信する必要があると考えています。または、244.xxx アドレスでマルチキャスト ソケットを作成することにより、私のルーター (コンピューター ネットワーク インターフェイス カード?) は、私のアドレスが 127.0.0.0 であることを認識し、送信者が同じアドレスでマルチキャスト ソケットを作成することによって、ルーター (NIC?) はそれを送信することを認識します。また私に？
Ubuntu Oneric、Eclipse IDE、Java の使用
ソース：
MIS
public class MulticastImageSender
{
private static final int TIMEOUT = 3000; // Time between sends (milliseconds)
private static final int MAXFILELEN = 65000; // File must fit in single datagram
public static void main(String[] args) throws IOException, InterruptedException
{
if (args.length < 4) // Test for correct # of args
throw new IllegalArgumentException("Parameter(s): <Multicast Address> <Port> <TTL> <Image File> [<Image File>...]");
InetAddress multicastAddress = InetAddress.getByName(args[0]);
int destPort = Integer.parseInt(args[1]);
// Destination port of multicast packets
int TTL = Integer.parseInt(args[2]);
// Create a UDP multicast socket with any available local port
MulticastSocket socket = new MulticastSocket();
socket.setTimeToLive(TTL);
// Set the TTL
for (int i=3; i < args.length; i++)
{
RandomAccessFile file = new RandomAccessFile(args[i], "r");
if (file.length() > MAXFILELEN)
throw new IOException("File too big");
byte [] fileBuffer = new byte[(int) file.length()];
file.read(fileBuffer);
file.close();
// Create a datagram to send
DatagramPacket sendPacket = new DatagramPacket(fileBuffer, fileBuffer.length, multicastAddress, destPort);
socket.send(sendPacket); // Send the echo string
System.out.println("Sent " + args[i] + " to " + sendPacket.getAddress().getHostAddress() + " on port " + sendPacket.getPort());
Thread.sleep(TIMEOUT);
}
socket.close();
}
}
MIR とそのサポート スレッド
import java.awt.event.*;
import javax.swing.*;
import java.net.*;
import java.io.*;
public class MulticastImageReceiver extends JFrame
{
private static final long serialVersionUID = 1L;
private JLabel picture;
// Label to contain image
public MulticastImageReceiver()
{
super("Multicast Image Receiver"); // Set the window title
setSize(300, 300);
// Set the window size
picture = new JLabel("No image", SwingConstants.CENTER);
JScrollPane scrollPane = new JScrollPane(picture);
getContentPane().add(scrollPane, "Center");
addWindowListener(new WindowAdapter() { public void windowClosing(WindowEvent evt){ System.exit(0);}});
}
public JLabel getPicture()
{
return picture;
}
public static void main(String[] args) throws IOException
{
if (args.length != 2) // Test for correct # of args
throw new IllegalArgumentException( "Parameter(s): <Multicast Address> <Port>");
final InetAddress multicastAddress = InetAddress.getByName(args[0]);
if (!multicastAddress.isMulticastAddress())
throw new IllegalArgumentException("Not a multicast address");
int port = Integer.parseInt(args[1]);
// Destination port of multicast packets
MulticastImageReceiver multicastImageReceiver = new MulticastImageReceiver();
multicastImageReceiver.setVisible(true);
new Thread(new MulticastImageReceiverThread(multicastImageReceiver, multicastAddress, port,"No Image")).start();
}
}
ミールスレッド
import java.awt.*;
import javax.swing.*;
import java.net.*;
import java.io.*;
class MulticastImageReceiverThread implements Runnable
{
private static final int MAXFILELEN = 65000;
// File must fit in single datagram
private InetAddress multicastAddress;
// Sender multicast address
private int port;
// Sender port
Runnable updateImage;
// Anonymous class for Swing event queue to update label
String imageText;
// Label text
byte[] image = new byte[MAXFILELEN];
// Bytes of image
boolean imageValid = false;
// True if image contains valid bytes
public MulticastImageReceiverThread(final MulticastImageReceiver frame, InetAddress multicastAddress, int port, String initialImageText)
{
this.multicastAddress = multicastAddress;
this.port = port;
this.imageText = initialImageText;
updateImage = new Runnable()
{
public void run()
{
JLabel picture = frame.getPicture();
picture.setText(imageText);
if (imageValid)
{
ImageIcon newImage = new ImageIcon(image);
picture.setIcon(newImage);
picture.setPreferredSize(new Dimension(newImage.getIconWidth(), newImage.getIconHeight()));
}
else
picture.setIcon(null);
picture.revalidate();
}
};
}
public void changeImage()
{
try
{
SwingUtilities.invokeAndWait(updateImage);
// Put update in queue and wait until handled
}
catch (Exception e)
{
System.out.println(e.getMessage());}
}
public void run()
{
// Create a datagram to receive
DatagramPacket recvPacket = new DatagramPacket(image, MAXFILELEN);
MulticastSocket socket;
// Create a UDP multicast socket with the specified local port
try
{
socket = new MulticastSocket(port);
socket.joinGroup(multicastAddress); // Join the multicast group
}
catch (IOException e)
{
imageText = "Problem with multicast socket";
imageValid = false; changeImage(); return;
}
for (;;)
{
try
{
socket.receive(recvPacket); // Receive the image
}
catch (IOException e)
{ break; }
// Assume exception due to file closing
imageText = "";
imageValid = true;
changeImage();
recvPacket.setLength(MAXFILELEN);
// You have to reset this!!!
}
}
}