Skip to content
Snippets Groups Projects
Commit f979f42d authored by unknown's avatar unknown
Browse files

remover banking

parent a66e3392
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 1 addition and 403 deletions
.gitignore 0 → 100644
+ 1
− 0
View file @ f979f42d
banking-server/target/
banking/banking.iml deleted 100644 → 0
+ 0
− 11
View file @ a66e3392
<?xml version="1.0" encoding="UTF-8"?>
<module type="JAVA_MODULE" version="4">
<component name="NewModuleRootManager" inherit-compiler-output="true">
<exclude-output />
<content url="file://$MODULE_DIR$">
<sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
</component>
</module>
\ No newline at end of file
banking/src/ufrn/imd/BankingServerApp.java deleted 100644 → 0
+ 0
− 26
View file @ a66e3392
package ufrn.imd;
import ufrn.imd.controller.Controller;
import ufrn.imd.controller.impl.BalanceControllerImpl;
import ufrn.imd.controller.impl.DepositControllerImpl;
import ufrn.imd.service.BalanceService;
import ufrn.imd.service.DepositService;
import ufrn.imd.service.impl.BalanceServiceImpl;
import ufrn.imd.service.impl.DepositServiceImpl;
import java.net.MalformedURLException;
import java.rmi.AlreadyBoundException;
import java.rmi.RemoteException;
public class BankingServerApp {
public static void main(String[] args) throws RemoteException, MalformedURLException, AlreadyBoundException {
DepositService depositService = new DepositServiceImpl();
BalanceService balanceService = new BalanceServiceImpl();
Controller depositController = new DepositControllerImpl(depositService);
Controller balanceController = new BalanceControllerImpl(balanceService);
}
}
banking/src/ufrn/imd/controller/Controller.java deleted 100644 → 0
+ 0
− 12
View file @ a66e3392
package ufrn.imd.controller;
import ufrn.imd.domain.Client;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.List;
public interface Controller extends Remote {
public void registerClient(Client client) throws RemoteException;
}
banking/src/ufrn/imd/controller/impl/BalanceControllerImpl.java deleted 100644 → 0
+ 0
− 94
View file @ a66e3392
package ufrn.imd.controller.impl;
import ufrn.imd.controller.Controller;
import ufrn.imd.domain.Client;
import ufrn.imd.service.BalanceService;
import ufrn.imd.service.DepositService;
import ufrn.imd.service.impl.BalanceServiceImpl;
import ufrn.imd.utils.Log;
import java.net.MalformedURLException;
import java.rmi.AlreadyBoundException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.server.UnicastRemoteObject;
import java.util.ArrayList;
import java.util.List;
import static ufrn.imd.utils.NameSpace.*;
public class BalanceControllerImpl extends UnicastRemoteObject implements Controller {
private volatile List<Client> clients = new ArrayList<>();
public BalanceControllerImpl(BalanceService service) throws RemoteException, MalformedURLException, AlreadyBoundException {
super();
Log.info(BalanceServiceImpl.class, "Starting Deposit service!");
new Notify(service).start();
Log.info(BalanceServiceImpl.class,
String.format("Initializing server in %s", HOST_BALANCE_SERVICE));
LocateRegistry.createRegistry(PORT_BALANCE_SERVICE);
Naming.bind(HOST_BALANCE_SERVICE, this);
}
@Override
public void registerClient(Client client) throws RemoteException {
clients.add(client);
Log.info(BalanceService.class, "new client registred");
Log.info(BalanceService.class, String.format("total users: %d", clients.size()));
}
private class Notify extends Thread{
private final BalanceService service;
public Notify(BalanceService service) {
super();
this.service = service;
}
public void run() {
for(;;) {
if(clients.size() > 0) {
Log.info(
BalanceService.class,
"notyfing the clients!"
);
int i = 0;
for (Client client : clients) {
try {
this.service.balance(client.getAccount());
} catch (RemoteException e) {
e.printStackTrace();
}
}
try {
Thread.sleep(15 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
try {
Thread.sleep(15 * 1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
Log.info(BalanceService.class, "No there's clients!");
}
}
}
}
}
banking/src/ufrn/imd/controller/impl/DepositControllerImpl.java deleted 100644 → 0
+ 0
− 94
View file @ a66e3392
package ufrn.imd.controller.impl;
import ufrn.imd.controller.Controller;
import ufrn.imd.utils.Log;
import ufrn.imd.domain.Client;
import ufrn.imd.service.DepositService;
import java.net.MalformedURLException;
import java.rmi.AlreadyBoundException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.server.UnicastRemoteObject;
import java.util.ArrayList;
import java.util.List;
import static ufrn.imd.utils.NameSpace.HOST_DEPOSIT_SERVICE;
import static ufrn.imd.utils.NameSpace.PORT_DEPOSIT_SERVICE;
public class DepositControllerImpl extends UnicastRemoteObject implements Controller {
private volatile List<Client> clients = new ArrayList<>();
public DepositControllerImpl(DepositService service) throws RemoteException, MalformedURLException, AlreadyBoundException {
super();
Log.info(DepositControllerImpl.class, "Starting Deposit service!");
new Notify(service).start();
Log.info(DepositControllerImpl.class,
String.format("Initializing server in %s", HOST_DEPOSIT_SERVICE));
LocateRegistry.createRegistry(PORT_DEPOSIT_SERVICE);
Naming.bind(HOST_DEPOSIT_SERVICE, this);
}
@Override
public void registerClient(Client client) throws RemoteException {
clients.add(client);
Log.info(DepositControllerImpl.class, "new client registred");
Log.info(DepositControllerImpl.class, String.format("total users: %d", clients.size()));
}
private class Notify extends Thread{
private final DepositService service;
public Notify(DepositService service) {
super();
this.service = service;
}
public void run() {
for(;;) {
if(clients.size() > 0) {
Log.info(
DepositControllerImpl.class,
"notyfing the clients!"
);
int i = 0;
for (Client client : clients) {
try {
this.service.deposit(client.getBalance(), client.getAccount());
} catch (RemoteException e) {
e.printStackTrace();
}
}
try {
Thread.sleep(15 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
try {
Thread.sleep(15 * 1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
Log.info(DepositControllerImpl.class, "No there's clients!");
}
}
}
}
}
banking/src/ufrn/imd/domain/Account.java deleted 100644 → 0
+ 0
− 41
View file @ a66e3392
package ufrn.imd.domain;
import java.io.Serializable;
public class Account implements Serializable {
private static final long serialVersionUID = 2L;
private Integer id;
private String number;
private Double balance;
public Account() {}
public Account(Integer id, String number, Double balance) {
this.id = id;
this.number = number;
this.balance = balance;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getNumber() {
return number;
}
public void setNumber(String number) {
this.number = number;
}
public Double getBalance() {
return balance;
}
public void setBalance(Double balance) {
this.balance = balance;
}
}
banking/src/ufrn/imd/domain/Client.java deleted 100644 → 0
+ 0
− 17
View file @ a66e3392
package ufrn.imd.domain;
import ufrn.imd.domain.Account;
import java.io.Serializable;
import java.util.Optional;
public class Client implements Serializable {
private static final long serialVersionUID = 1L;
private Account account;
public Double getBalance() {
return account.getBalance();
}
public Optional<Account> getAccount() {
return Optional.of(account);
}
}
banking/src/ufrn/imd/repository/Repository.java deleted 100644 → 0
+ 0
− 2
View file @ a66e3392
package ufrn.imd.repository;public interface Repository {
}
banking/src/ufrn/imd/repository/impl/ClientRepository.java deleted 100644 → 0
+ 0
− 2
View file @ a66e3392
package ufrn.imd.repository.impl;public class ClientRepository {
}
banking/src/ufrn/imd/service/BalanceService.java deleted 100644 → 0
+ 0
− 12
View file @ a66e3392
package ufrn.imd.service;
import ufrn.imd.domain.Account;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.Optional;
public interface BalanceService extends Remote {
public void balance(Optional<Account> account) throws RemoteException;
}
banking/src/ufrn/imd/service/DepositService.java deleted 100644 → 0
+ 0
− 13
View file @ a66e3392
package ufrn.imd.service;
import ufrn.imd.domain.Account;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.Optional;
public interface DepositService extends Remote {
public void deposit(Double value, Optional<Account> account) throws RemoteException, RuntimeException;
}
banking/src/ufrn/imd/service/WidthawService.java deleted 100644 → 0
+ 0
− 12
View file @ a66e3392
package ufrn.imd.service;
import ufrn.imd.domain.Account;
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface WidthawService extends Remote {
public void widthaw(Double value, Account account) throws RemoteException;
}
banking/src/ufrn/imd/service/impl/BalanceServiceImpl.java deleted 100644 → 0
+ 0
− 23
View file @ a66e3392
package ufrn.imd.service.impl;
import ufrn.imd.domain.Account;
import java.rmi.RemoteException;
import java.util.Optional;
import ufrn.imd.service.*;
import ufrn.imd.utils.Log;
public class BalanceServiceImpl implements BalanceService {
@Override
public void balance(Optional<Account> accOP) throws RemoteException {
Account account = accOP.orElseThrow(() -> new RuntimeException("Invalid account"));
Log.info(
BalanceServiceImpl.class,
String.format("Account Balance: R$ %f", account.getBalance())
);
}
}
banking/src/ufrn/imd/service/impl/DepositServiceImpl.java deleted 100644 → 0
+ 0
− 23
View file @ a66e3392
package ufrn.imd.service.impl;
import ufrn.imd.domain.Account;
import ufrn.imd.utils.Log;
import ufrn.imd.service.DepositService;
import java.rmi.RemoteException;
import java.util.Optional;
public class DepositServiceImpl implements DepositService {
public DepositServiceImpl() {
super();
}
public void deposit(Double value, Optional<Account> acOp) throws RemoteException, RuntimeException {
Account account = acOp.orElseThrow(() -> new RuntimeException("Null User!"));
if(account.getBalance() < value) throw new RuntimeException("There's no money!");
account.setBalance(account.getBalance() - value);
Log.info(DepositServiceImpl.class, "deposit");
}
}
banking/src/ufrn/imd/utils/Log.java deleted 100644 → 0
+ 0
− 10
View file @ a66e3392
package ufrn.imd.utils;
public class Log {
public static void info(Class path, String text) {
System.out.println(
String.format("[LOG] %s - %s", path , text)
);
}
}
banking/src/ufrn/imd/utils/NameSpace.java deleted 100644 → 0
+ 0
− 11
View file @ a66e3392
package ufrn.imd.utils;
public class NameSpace {
public final static Integer PORT_BALANCE_SERVICE = 1908;
public final static Integer PORT_DEPOSIT_SERVICE = 1907;
public final static String HOST_DEPOSIT_SERVICE =
String.format("rmi://127.0.0.1:%d/%s", PORT_DEPOSIT_SERVICE, "deposit");
public final static String HOST_BALANCE_SERVICE =
String.format("rmi://127.0.0.1:%d/%s", PORT_BALANCE_SERVICE, "balance");
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment