Ivan Pešić: Исправка

2021-11-29T18:40:55Z

Исправка

← Старија измена		Верзија на датум 29. новембар 2021. у 20:40
Ред 141:		Ред 141:
	producer.send(myQueue, objMsg);		producer.send(myQueue, objMsg);
	System.out.println("Sent " + obj);		System.out.println("Sent " + obj);
	int wait = (int)((Math.random() * 3 + 3) * 1000);		int wait = (int)((Math.random() * 4 + 3) * 1000);
	Thread.sleep(wait);		Thread.sleep(wait);
	} catch (InterruptedException \| JMSException ex) {		} catch (InterruptedException \| JMSException ex) {

KockaAdmiralac: Postavka (od `<@389896576987824139>`) i rešenje

2021-11-16T17:38:59Z

Postavka (od `<@389896576987824139>`) i rešenje

Нова страница

{{tocright}}

== Zadatak 1b ==
Posmatra se proces za sklapanje automobila. Radnici RA, RB i RC prave delove A, B, C respektivno. Delovi su instance klasa A, B, C. Dakle, sklopljeni deo radnik šalje unutar objektne poruke u red za sklapanje koji je zajednički za sve radnike. Radnik kada napravi deo čeka između 3 i 6 sekundi (sa uniformnom raspodelom) i kreće sa pravljenjem novog dela. Sve delove iz reda za sklapanje prikuplja poseban radnik koji radi samo sklapanje automobila. Svaki automobil sastoji se iz tačno jednog dela A, jednog dela B i jednog dela C. Kada prikupi sva tri različita dela koja su prva pristigla (nije dozvoljeno da skladišti više delova istog tipa), radnik od njih pravi automobil koji je predstavljen klasom Automobil koja u sebi ima reference na svoja tri dela. Radniku je za sklapanje automobila potrebno 5 sekundi i sve sklopljene automobile šalje u posebnu temu za testiranje. Radnici za testiranje preuzimaju automobile sa te teme. Potrebno je omogućiti da radnici za testiranje primaju poruke koje su pristigle i u periodu kada niko nije bio aktivan i da svaki automobil preuzme samo jedan radnik. Slanje i prijem svake poruke je potrebno ispisati na glavnom izlazu.

=== Rešenje ===
Pre pokretanja u Glassfish napraviti Queue sa nazivom <code>myQueue</code> i Topic sa nazivom <code>MyTopic</code>, dok takođe treba da postoji podrazumevani Connection Factory <code>jms/__defaultConnectionFactory</code>. Radnici treba da se nalaze u odvojenim projektima kako bi mogli da se pokreću odvojeno, dok ostali paketi mogu da se nalaze u svim projektima.

==== <code>delovi</code> paket ====
Ovaj paket mora biti u sva tri projekta kako bi procesi uspešno razmenjivali poruke.

===== <code>A.java</code> =====
<syntaxhighlight lang="java">
package delovi;

import java.io.Serializable;

public class A implements Serializable {
private final int id;
public A(int id) {
this.id = id;
}
@Override
public String toString() {
return "A[" + id + "]";
}
}
</syntaxhighlight>

===== <code>B.java</code> =====
<syntaxhighlight lang="java">
package delovi;

import java.io.Serializable;

public class B implements Serializable {
private final int id;
public B(int id) {
this.id = id;
}
@Override
public String toString() {
return "B[" + id + "]";
}
}
</syntaxhighlight>

===== <code>C.java</code> =====
<syntaxhighlight lang="java">
package delovi;

import java.io.Serializable;

public class C implements Serializable {
private final int id;
public C(int id) {
this.id = id;
}
@Override
public String toString() {
return "C[" + id + "]";
}
}
</syntaxhighlight>

==== <code>automobil</code> paket ====
Ovaj paket mora da se nalazi i u projektu sa radnikom sklapačem i u projektu sa radnicima testerima.

===== <code>Automobil.java</code> =====
<syntaxhighlight lang="java">
package automobil;

import delovi.*;
import java.io.Serializable;

public class Automobil implements Serializable {
private final A a;
private final B b;
private final C c;

public Automobil(A a, B b, C c) {
this.a = a;
this.b = b;
this.c = c;
}

@Override
public String toString() {
return "Automobil[" + a + ", " + b + "," + c + "]";
}
}
</syntaxhighlight>

==== <code>radnikdelova</code> paket ====
===== <code>RadnikDelova.java</code> =====
Predstavlja radnike RA, RB i RC. Pokrenuti tri puta menjajući <code>PART_NAME</code>.
<syntaxhighlight lang="java">
package radnikdelova;

import java.io.Serializable;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.Resource;
import javax.jms.ConnectionFactory;
import javax.jms.JMSContext;
import javax.jms.JMSException;
import javax.jms.JMSProducer;
import javax.jms.Queue;
import javax.jms.ObjectMessage;
import delovi.*;

public class Main {
@Resource(lookup="jms/__defaultConnectionFactory")
private static ConnectionFactory connectionFactory;

@Resource(lookup="myQueue")
private static Queue myQueue;

private static final char PART_NAME = 'A';
private static int staticId = 0;

public static void main(String[] args) {
JMSContext context = connectionFactory.createContext();
JMSProducer producer = context.createProducer();
while (true) {
try {
Serializable obj = null;
switch (PART_NAME) {
case 'A':
obj = new A(staticId++);
break;
case 'B':
obj = new B(staticId++);
break;
case 'C':
obj = new C(staticId++);
break;
}
ObjectMessage objMsg = context.createObjectMessage(obj);
objMsg.setStringProperty("Type", String.valueOf(PART_NAME));
producer.send(myQueue, objMsg);
System.out.println("Sent " + obj);
int wait = (int)((Math.random() * 3 + 3) * 1000);
Thread.sleep(wait);
} catch (InterruptedException | JMSException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
</syntaxhighlight>

==== <code>radniksklapac</code> paket ====
===== <code>RadnikSklapac.java</code> =====
<syntaxhighlight lang="java">
package radniksklapac;

import automobil.Automobil;
import delovi.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.Resource;
import javax.jms.ConnectionFactory;
import javax.jms.JMSConsumer;
import javax.jms.JMSContext;
import javax.jms.JMSException;
import javax.jms.JMSProducer;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.ObjectMessage;
import javax.jms.Topic;

public class Main {
@Resource(lookup="jms/__defaultConnectionFactory")
private static ConnectionFactory connectionFactory;

@Resource(lookup="myQueue")
private static Queue myQueue;

@Resource(lookup="MyTopic")
private static Topic myTopic;

public static void main(String[] args) {
JMSContext context = connectionFactory.createContext();
JMSConsumer consumerA = context.createConsumer(myQueue, "Type = 'A'");
JMSConsumer consumerB = context.createConsumer(myQueue, "Type = 'B'");
JMSConsumer consumerC = context.createConsumer(myQueue, "Type = 'C'");
JMSProducer producer = context.createProducer();
while (true) {
Message msgA = consumerA.receive();
System.out.println("Received A");
Message msgB = consumerB.receive();
System.out.println("Received B");
Message msgC = consumerC.receive();
System.out.println("Received C");
if (msgA instanceof ObjectMessage && msgB instanceof ObjectMessage && msgC instanceof ObjectMessage) {
try {
ObjectMessage objMsgA = (ObjectMessage)msgA;
ObjectMessage objMsgB = (ObjectMessage)msgB;
ObjectMessage objMsgC = (ObjectMessage)msgC;
A a = (A)objMsgA.getObject();
B b = (B)objMsgB.getObject();
C c = (C)objMsgC.getObject();
Automobil auto = new Automobil(a, b, c);
Thread.sleep(5000);
System.out.println("Produced " + auto);
ObjectMessage autoMsg = context.createObjectMessage(auto);
producer.send(myTopic, autoMsg);
} catch (JMSException | InterruptedException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
}
</syntaxhighlight>

==== <code>radniktester</code> paket ====
===== <code>RadnikTester.java</code> =====
<syntaxhighlight lang="java">
package radniktester;

import automobil.Automobil;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.Resource;
import javax.jms.ConnectionFactory;
import javax.jms.JMSConsumer;
import javax.jms.JMSContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.ObjectMessage;
import javax.jms.Topic;

public class Main {
@Resource(lookup="jms/__defaultConnectionFactory")
private static ConnectionFactory connectionFactory;

@Resource(lookup="MyTopic")
private static Topic myTopic;

public static void main(String[] args) {
JMSContext context = connectionFactory.createContext();
JMSConsumer consumer = context.createSharedDurableConsumer(myTopic, "sub1");
while (true) {
try {
Message msg = consumer.receive();
System.out.println("Received car");
if (msg instanceof ObjectMessage) {
Automobil auto = (Automobil)((ObjectMessage) msg).getObject();
System.out.println("Received " + auto);
}
} catch (JMSException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
</syntaxhighlight>

[[Категорија:Информациони системи 1]]
[[Категорија:Лабораторијске вежбе]]

Информациони системи 1/Лаб 1 2020 - Историја измена

Ivan Pešić: Исправка

KockaAdmiralac: Postavka (od `<@389896576987824139>`) i rešenje