私たちの先生は、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？）はそれを送信することを認識します。もう一度私に？
**私はこの質問を一度投稿しましたが無駄になりました。私が受け取っているエラーはこの行からのものであることに気づきました
if (!multicastAddress.isMulticastAddress())
私はこれらすべてを学び、実際に割り当てを開始できるように、このプログラムを実際に実行する方法を理解しようとしています。必要なのは、使用するアドレスとその理由を簡単に説明することだけです。
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();
}
}
MIRスレッド
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!!!
}
}
}