Wie kann ich Verbindungsinformationen an eine ausführbare Datei übergeben?

Question

Ich habe Probleme beim Übergeben einiger Verbindungsinformationen an einen ausführbaren Thread (unter Verwendung von rabbitmq, aber ich denke nicht, dass dies spezifisch für rabbitmq ist und sich auf alles anwenden lässt). Mein Ziel ist es, ein paar Worker-Threads zu haben, die einige Arbeiten aus einer Warteschlange verarbeiten, aber ich möchte nicht, dass jedes Mal Verbindungen geöffnet und geschlossen werden.

Der Code funktioniert ohne runnable (es ist eigentlich aus den rabbitmq Tutorials gestohlen), aber sobald ich ein lauffähiges implementieren eine Verbindung geben ich auf doWork diesen Fehler(): The method doWork(Channel, String) is undefined for the type Worker Wenn ich entfernen Kanal von runnable und nicht Senden Sie es dann das Programm funktioniert gut, aber die Verbindungsinformationen werden nicht übergeben. Was kann ich tun?

Hier ist mein Code:

 //this is the standard stuff to start a connection 
ConnectionFactory factory = new ConnectionFactory(); 
      factory.setHost("localhost"); 
      Connection connection = factory.newConnection(); 
      Channel channel = connection.createChannel(); 

     System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); 

     channel.basicQos(1); 

     QueueingConsumer consumer = new QueueingConsumer(channel); 
     channel.basicConsume("task_queue", false, consumer); 
     //end of standard stuff  

     while (true) { 
      QueueingConsumer.Delivery delivery = consumer.nextDelivery(); 
      String message = new String(delivery.getBody()); 

      System.out.println(" [x] Received '" + message + "'"); 
      doWork(channel, message); 
      System.out.println(" [x] Done"); 

      channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); 
     } 
     } 

dann:

public class doWork implements Runnable{ 

     protected Channel channel = null; 
     protected String message = null; 

     public doWork(Channel channel, String message) { 
      this.channel = channel; 
      this.message = message; 
     } 


     public void run() { 

Answer 1

Wenn Sie Ihren Code in eine ausführbare Datei verschoben haben, bedeutet dies, dass Sie eine neue Klasse erstellt haben. Wenn Sie es aufrufen möchten, dann sollten Sie so etwas wie dieses

doWork work = new doWork(channel, message); 
work.run(); 

haben, aber Sie wollen wahrscheinlich alles, was zu einem Außengewinde zu bewegen, die von getan wird: Btw

Thread t = new Thread(new doWork(channel, message)); 
t.start(); 

, Klassen sollten Beginnen Sie mit einem Großbuchstaben, dadurch wird der Code deutlich lesbarer.

Answer 2

Sie versuchen, eine Methode doWork Namen zu nennen:

// this is a method call 
doWork(channel, message); 

Was Sie tun wollen (ich glaube) ist etwas wie:

aber wahrscheinlicher Sie versuchen, einen Thread gibt Gabel soll es so sein würde:

new Thread(new doWork(channel, message)).start(); 

Als Nebenwirkung, sollten Sie Ihre Klassennamen nutzen, die es leichter zu sehen wäre. doWork sollte in DoWork umbenannt werden, dann ist es einfacher, den Unterschied zwischen Methodennamen und Klassennamen zu sehen. Methodennamen sollten immer mit einem Kleinbuchstaben beginnen.

Answer 3

Irgendwo in Ihrer Worker Klasse haben Sie eine Methode doWork(String message) definiert. Was innerhalb Ihrer Klasse doWork definiert ist (dessen Name nicht den Java-Konventionen folgt, btw), spielt keine Rolle, bis Sie eine Instanz dieser Klasse erstellt und die Methode für diese Instanz aufgerufen haben. Sie versuchen derzeit, eine Methode der Klasse Worker aufzurufen.