Oktatóanyag: Alkalmazás létrehozása Java API előtér-szolgáltatással és állapotalapú háttérszolgáltatással az Azure Service Fabricben
Ez az oktatóanyag egy sorozat első része. Ha végzett, egy Java webes előtérrel rendelkező szavazóalkalmazással rendelkezik, amely egy állapotalapú háttérszolgáltatásban menti a szavazási eredményeket az Azure Service Fabricben. Az oktatóanyag elvégzésének egyik feltétele, hogy rendelkezzen egy működő Mac OSX vagy Linux fejlesztői géppel. Ha nem szeretné manuálisan létrehozni a szavazóalkalmazást, letöltheti a befejezett alkalmazás forráskódját , és továbbléphet a szavazási mintaalkalmazás végigjárására. Érdemes lehet követni a Java reliable services rövid útmutatóját is.
Ebben az oktatóanyag-sorozatban az alábbiakkal ismerkedhet meg:
- Service Fabric Reliable Services Java-alkalmazás létrehozása
- Az alkalmazás üzembe helyezése és hibakeresése egy helyi fürtön
- Alkalmazás üzembe helyezése egy Azure-fürtön
- Figyelés és diagnosztika beállítása az alkalmazáshoz
- CI/CD beállítása
A sorozat első részében a következőkkel ismerkedhet meg:
- Állapotalapú megbízható Java-szolgáltatás létrehozása
- Állapot nélküli Java-webalkalmazásszolgáltatás létrehozása
- Szolgáltatás távelérésének lehetővé tétele az állapotalapú szolgáltatással folytatott kommunikációhoz
- Alkalmazás üzembe helyezése helyi Service Fabric-fürtön
Előfeltételek
Az oktatóanyag elkezdése előtt:
- Ha nem rendelkezik Azure-előfizetéssel, hozzon létre egy ingyenes fiókot.
- Állítsa be a fejlesztési környezetet Mac vagy Linux rendszerhez. Az utasításokat követve telepítse a következőket: Eclipse beépülő modul, Gradle, Service Fabric SDK és Service Fabric parancssori felület (sfctl).
A kezelőfelületi állapotmentes Java-szolgáltatás létrehozása
Először hozza létre a szavazóalkalmazás webes kezelőfelületét. Az AngularJS által üzemeltetett webes felhasználói felület kéréseket küld a Java állapot nélküli szolgáltatásának, amely egy egyszerűsített HTTP-kiszolgálót futtat. Ez a szolgáltatás feldolgozza az egyes kéréseket, és távoli eljáráshívást küld az állapotalapú szolgáltatásnak a szavazatok tárolásához.
Nyissa meg az Eclipse környezetet.
Hozzon létre egy projektet a File>New>Other>Service Fabric>Service Fabric Project paranccsal.
A ServiceFabric Projekt varázsló párbeszédpanelen nevezze el a Project Voting nevet, majd válassza a Tovább gombot.
A Szolgáltatás hozzáadása lapon válassza az Állapot nélküli szolgáltatás lehetőséget, és nevezze el a szolgáltatást VotingWeb néven. A projekt létrehozásához válassza a Befejezés lehetőséget.
Az Eclipse létrehoz egy alkalmazás- és egy szolgáltatásprojektet, és megjeleníti őket a Package Explorerben.
A táblázat röviden ismerteti az előző képernyőképen látható Package Explorer összes elemét.
| Package Explorer-elem | Leírás |
|---|---|
| PublishProfiles | A helyi és Azure-beli Service Fabric-fürtök profilrészleteit ismertető JSON-fájlokat tartalmazza. A fájlok tartalmát a beépülő modul használja az alkalmazás üzembe helyezésekor. |
| Parancsfájlok | Olyan segítő szkripteket tartalmaz, amelyek segítségével a parancssorról gyorsan kezelhető az alkalmazás egy fürttel. |
| VotingApplication | A Service Fabric-fürtön közzétett Service Fabric-alkalmazást tartalmazza. |
| VotingWeb | A kezelőfelületi állapotmentes szolgáltatás forrásfájljait és a kapcsolódó Gradle-buildfájlt tartalmazza. |
| build.gradle | A projekt kezeléséhez használt Gradle-fájl. |
| settings.gradle | Az ebben a mappában lévő Gradle-projektek nevét tartalmazza. |
HTML és JavaScript hozzáadása a VotingWeb szolgáltatáshoz
Az állapot nélküli szolgáltatás által megjeleníthető felhasználói felület hozzáadásához adjon hozzá egy HTML-fájlt. Ezt a HTML-fájlt aztán az állapotmentes Java-szolgáltatásba ágyazott egyszerűsített HTTP-kiszolgáló jeleníti meg.
A VotingApplication/VotingWebPkg/Code eléréséhez bontsa ki a VotingApplication könyvtárat.
Kattintson a jobb gombbal a Kód könyvtárra, és válassza az Új>mappa lehetőséget.
Nevezze el a mappát wwwroot névvel, és válassza a Befejezés lehetőséget.
Adjon hozzá egy index.html nevű fájlt a wwwroot mappához, és illessze be az alábbi tartalmakat ebbe a fájlba.
<!DOCTYPE html>
<html>
<script src="https://ajax.googleapis.com/ajax/libs/angularjs/1.6.4/angular.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/angular-ui-bootstrap/0.13.4/ui-bootstrap-tpls.min.js"></script>
<link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.7/css/bootstrap.min.css">
<body>
<script>
var app = angular.module('VotingApp', ['ui.bootstrap']);
app.controller("VotingAppController", ['$rootScope', '$scope', '$http', '$timeout', function ($rootScope, $scope, $http, $timeout) {
$scope.votes = [];
$scope.refresh = function () {
$http.get('getStatelessList')
.then(function successCallback(response) {
$scope.votes = Object.assign(
{},
...Object.keys(response.data) .
map(key => ({[decodeURI(key)]: response.data[key]}))
)
},
function errorCallback(response) {
alert(response);
});
};
$scope.remove = function (item) {
$http.get("removeItem", {params: { item: encodeURI(item) }})
.then(function successCallback(response) {
$scope.refresh();
},
function errorCallback(response) {
alert(response);
});
};
$scope.add = function (item) {
if (!item) {return;}
$http.get("addItem", {params: { item: encodeURI(item) }})
.then(function successCallback(response) {
$scope.refresh();
},
function errorCallback(response) {
alert(response);
});
};
}]);
</script>
<div ng-app="VotingApp" ng-controller="VotingAppController" ng-init="refresh()">
<div class="container-fluid">
<div class="row">
<div class="col-xs-8 col-xs-offset-2 text-center">
<h2>Service Fabric Voting Sample</h2>
</div>
</div>
<div class="row">
<div class="col-xs-offset-2">
<form style="width:50% ! important;" class="center-block">
<div class="col-xs-6 form-group">
<input id="txtAdd" type="text" class="form-control" placeholder="Add voting option" ng-model="item" />
</div>
<button id="btnAdd" class="btn btn-default" ng-click="add(item)">
<span class="glyphicon glyphicon-plus" aria-hidden="true"></span>
Add
</button>
</form>
</div>
</div>
<hr />
<div class="row">
<div class="col-xs-8 col-xs-offset-2">
<div class="row">
<div class="col-xs-4">
Click to vote
</div>
</div>
<div class="row top-buffer" ng-repeat="(key, value) in votes">
<div class="col-xs-8">
<button class="btn btn-success text-left btn-block" ng-click="add(key)">
<span class="pull-left">
{{key}}
</span>
<span class="badge pull-right">
{{value}} Votes
</span>
</button>
</div>
<div class="col-xs-4">
<button class="btn btn-danger pull-right btn-block" ng-click="remove(key)">
<span class="glyphicon glyphicon-remove" aria-hidden="true"></span>
Remove
</button>
</div>
</div>
</div>
</div>
</div>
</div>
</body>
</html>
A VotingWeb.java fájl frissítése
A VotingWeb alprojektben nyissa meg a VotingWeb/src/statelessservice/VotingWeb.java fájlt. A VotingWeb szolgáltatás az átjáró az állapotmentes szolgáltatásba, és ez felelős az előtérbeli API kommunikációs figyelőjének beállításáért.
Cserélje le a fájl meglévő createServiceInstanceListeners metódusát a következőre, és mentse a módosításokat.
@Override
protected List<ServiceInstanceListener> createServiceInstanceListeners() {
EndpointResourceDescription endpoint = this.getServiceContext().getCodePackageActivationContext().getEndpoint(webEndpointName);
int port = endpoint.getPort();
List<ServiceInstanceListener> listeners = new ArrayList<ServiceInstanceListener>();
listeners.add(new ServiceInstanceListener((context) -> new HttpCommunicationListener(context, port)));
return listeners;
}
A HTTPCommunicationListener.java fájl hozzáadása
A HTTP-kommunikáció figyelője úgy működik, mint egy vezérlő, amely beállítja a HTTP-kiszolgálót, és elérhetővé teszi a szavazási műveleteket meghatározó API-kat. Kattintson a jobb gombbal az állapot nélküli szolgáltatáscsomagra a VotingWeb/src/statelessservice mappában, majd válassza az Új>fájl lehetőséget. Nevezze el a httpCommunicationListener.java fájlt, és válassza a Befejezés lehetőséget.
Cserélje le a fájl tartalmát a következőkkel, majd mentse a módosításokat. A későbbiekben, a HttpCommunicationListener.java fájl frissítését ismertető szakaszban ez a fájl úgy módosul, hogy a háttérszolgáltatásból a szavazás adatait renderelni, olvasni és írni is tudja. Egyelőre a figyelő egyszerűen a szavazóalkalmazás statikus HTML-jét adja vissza.
// ------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License (MIT). See License.txt in the repo root for license information.
// ------------------------------------------------------------
package statelessservice;
import com.google.gson.Gson;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.Headers;
import java.io.File;
import java.io.OutputStream;
import java.io.FileInputStream;
import java.net.InetSocketAddress;
import java.net.URI;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.logging.Level;
import java.util.logging.Logger;
import microsoft.servicefabric.services.communication.runtime.CommunicationListener;
import microsoft.servicefabric.services.runtime.StatelessServiceContext;
import microsoft.servicefabric.services.client.ServicePartitionKey;
import microsoft.servicefabric.services.remoting.client.ServiceProxyBase;
import microsoft.servicefabric.services.communication.client.TargetReplicaSelector;
import system.fabric.CancellationToken;
public class HttpCommunicationListener implements CommunicationListener {
private static final Logger logger = Logger.getLogger(HttpCommunicationListener.class.getName());
private static final String HEADER_CONTENT_TYPE = "Content-Type";
private static final int STATUS_OK = 200;
private static final int STATUS_NOT_FOUND = 404;
private static final int STATUS_ERROR = 500;
private static final String RESPONSE_NOT_FOUND = "404 (Not Found) \n";
private static final String MIME = "text/html";
private static final String ENCODING = "UTF-8";
private static final String ROOT = "wwwroot/";
private static final String FILE_NAME = "index.html";
private StatelessServiceContext context;
private com.sun.net.httpserver.HttpServer server;
private ServicePartitionKey partitionKey;
private final int port;
public HttpCommunicationListener(StatelessServiceContext context, int port) {
this.partitionKey = new ServicePartitionKey(0);
this.context = context;
this.port = port;
}
// Called by openAsync when the class is instantiated
public void start() {
try {
logger.log(Level.INFO, "Starting Server");
server = com.sun.net.httpserver.HttpServer.create(new InetSocketAddress(this.port), 0);
} catch (Exception ex) {
logger.log(Level.SEVERE, null, ex);
throw new RuntimeException(ex);
}
// Responsible for rendering the HTML layout described in the previous step
server.createContext("/", new HttpHandler() {
@Override
public void handle(HttpExchange t) {
try {
File file = new File(ROOT + FILE_NAME).getCanonicalFile();
if (!file.isFile()) {
// Object does not exist or is not a file: reject with 404 error.
t.sendResponseHeaders(STATUS_NOT_FOUND, RESPONSE_NOT_FOUND.length());
OutputStream os = t.getResponseBody();
os.write(RESPONSE_NOT_FOUND.getBytes());
os.close();
} else {
Headers h = t.getResponseHeaders();
h.set(HEADER_CONTENT_TYPE, MIME);
t.sendResponseHeaders(STATUS_OK, 0);
OutputStream os = t.getResponseBody();
FileInputStream fs = new FileInputStream(file);
final byte[] buffer = new byte[0x10000];
int count = 0;
while ((count = fs.read(buffer)) >= 0) {
os.write(buffer,0,count);
}
fs.close();
os.close();
}
} catch (Exception e) {
logger.log(Level.WARNING, null, e);
}
}
});
/*
[Replace this entire comment block in the 'Connect the services' section]
*/
server.setExecutor(null);
server.start();
}
//Helper method to parse raw HTTP requests
private Map<String, String> queryToMap(String query){
Map<String, String> result = new HashMap<String, String>();
for (String param : query.split("&")) {
String pair[] = param.split("=");
if (pair.length>1) {
result.put(pair[0], pair[1]);
}else{
result.put(pair[0], "");
}
}
return result;
}
//Called closeAsync when the service is shut down
private void stop() {
if (null != server)
server.stop(0);
}
//Called by the Service Fabric runtime when this service is created on a node
@Override
public CompletableFuture<String> openAsync(CancellationToken cancellationToken) {
this.start();
logger.log(Level.INFO, "Opened Server");
String publishUri = String.format("http://%s:%d/", this.context.getNodeContext().getIpAddressOrFQDN(), port);
return CompletableFuture.completedFuture(publishUri);
}
//Called by the Service Fabric runtime when the service is shut down
@Override
public CompletableFuture<?> closeAsync(CancellationToken cancellationToken) {
this.stop();
return CompletableFuture.completedFuture(true);
}
//Called by the Service Fabric runtime to forcibly shut this listener down
@Override
public void abort() {
this.stop();
}
}
A figyelőport konfigurálása
A VotingWeb szolgáltatás kezelőfelületi szolgáltatás létrehozásakor a Service Fabric véletlenszerűen kiválaszt egy portot, amelyen a szolgáltatás a figyelést végzi. A VotingWeb szolgáltatás az alkalmazás kezelőfelületeként működik, és fogadja a külső forgalmat, úgyhogy rendeljük ezt a szolgáltatást egy rögzített, jól ismert porthoz. A Package Explorerben nyissa meg a VotingApplication/VotingWebPkg/ServiceManifest.xmlfájlt. Keresse meg a Végpont erőforrást az Erőforrások szakaszban, és módosítsa a Port értékét 8080-ra (az oktatóanyag során ezt a portot fogjuk használni). Az alkalmazás helyi üzembe helyezéséhez és futtatásához az alkalmazásfigyelő-portnak a számítógépen megnyitva és elérhető állapotban kell lennie. A ServiceManifest elemen belül illessze be az alábbi kódrészletet (közvetlenül az <DataPackage> elem alá).
<Resources>
<Endpoints>
<!-- This endpoint is used by the communication listener to obtain the port on which to
listen. Please note that if your service is partitioned, this port is shared with
replicas of different partitions that are placed in your code. -->
<Endpoint Name="WebEndpoint" Protocol="http" Port="8080" />
</Endpoints>
</Resources>
Állapotalapú háttérszolgáltatás hozzáadása az alkalmazáshoz
Most, hogy a webes Java API-szolgáltatás váza elkészült, haladjunk tovább, és fejezzük be az állapotalapú háttérszolgáltatást.
A Service Fabric megbízható gyűjtemények használatával konzisztens módon és megbízhatóan tárolja az adatokat a szolgáltatásban. A megbízható gyűjtemények magas rendelkezésre állású és megbízható gyűjteményosztályok. Az osztályok használatát mindenki jól ismerheti, aki már használt Java-gyűjteményeket.
A Package Explorerben kattintson a jobb gombbal a Szavazás elemre az alkalmazásprojekten belül, és válassza a Service Fabric>Service Fabric-szolgáltatás hozzáadása lehetőséget.
A Szolgáltatás hozzáadása párbeszédpanelen válassza az Állapotalapú szolgáltatás lehetőséget, nevezze el a szolgáltatást VotingDataService névvel , majd válassza a Szolgáltatás hozzáadása lehetőséget.
A szolgáltatásprojekt létrehozása után az alkalmazás két szolgáltatást fog tartalmazni. Miközben létrehozza az alkalmazást, hasonlóképpen adhat hozzá további szolgáltatásokat. Mindegyik – a többitől függetlenül – verziószámmal ellátható és frissíthető.
Az Eclipse létrehoz egy szolgáltatásprojektet, és megjeleníti a Package Explorerben.
A VotingDataService.java fájl hozzáadása
A VotingDataService.java fájl tartalmazza a szavazatok lekérésének, hozzáadásának és a megbízható gyűjteményekből való törlésének logikáját tartalmazó metódusokat. Adja hozzá az alábbi VotingDataService osztálymetódusokat a VotingDataService/src/statefulservice/VotingDataService.java fájlhoz.
package statefulservice;
import java.util.HashMap;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.AtomicInteger;
import microsoft.servicefabric.services.communication.runtime.ServiceReplicaListener;
import microsoft.servicefabric.services.runtime.StatefulService;
import microsoft.servicefabric.services.remoting.fabrictransport.runtime.FabricTransportServiceRemotingListener;
import microsoft.servicefabric.data.ReliableStateManager;
import microsoft.servicefabric.data.Transaction;
import microsoft.servicefabric.data.collections.ReliableHashMap;
import microsoft.servicefabric.data.utilities.AsyncEnumeration;
import microsoft.servicefabric.data.utilities.KeyValuePair;
import system.fabric.StatefulServiceContext;
import rpcmethods.VotingRPC;
class VotingDataService extends StatefulService implements VotingRPC {
private static final String MAP_NAME = "votesMap";
private ReliableStateManager stateManager;
protected VotingDataService (StatefulServiceContext statefulServiceContext) {
super (statefulServiceContext);
}
@Override
protected List<ServiceReplicaListener> createServiceReplicaListeners() {
this.stateManager = this.getReliableStateManager();
ArrayList<ServiceReplicaListener> listeners = new ArrayList<>();
listeners.add(new ServiceReplicaListener((context) -> {
return new FabricTransportServiceRemotingListener(context,this);
}));
return listeners;
}
// Method that will be invoked via RPC from the front end to retrieve the complete set of votes in the map
public CompletableFuture<HashMap<String,String>> getList() {
HashMap<String, String> tempMap = new HashMap<String, String>();
try {
ReliableHashMap<String, String> votesMap = stateManager
.<String, String> getOrAddReliableHashMapAsync(MAP_NAME).get();
Transaction tx = stateManager.createTransaction();
AsyncEnumeration<KeyValuePair<String, String>> kv = votesMap.keyValuesAsync(tx).get();
while (kv.hasMoreElementsAsync().get()) {
KeyValuePair<String, String> k = kv.nextElementAsync().get();
tempMap.put(k.getKey(), k.getValue());
}
tx.close();
} catch (Exception e) {
e.printStackTrace();
}
return CompletableFuture.completedFuture(tempMap);
}
// Method that will be invoked via RPC from the front end to add an item to the votes list or to increase the
// vote count for a particular item
public CompletableFuture<Integer> addItem(String itemToAdd) {
AtomicInteger status = new AtomicInteger(-1);
try {
ReliableHashMap<String, String> votesMap = stateManager
.<String, String> getOrAddReliableHashMapAsync(MAP_NAME).get();
Transaction tx = stateManager.createTransaction();
votesMap.computeAsync(tx, itemToAdd, (k, v) -> {
if (v == null) {
return "1";
}
else {
int numVotes = Integer.parseInt(v);
numVotes = numVotes + 1;
return Integer.toString(numVotes);
}
}).get();
tx.commitAsync().get();
tx.close();
status.set(1);
} catch (Exception e) {
e.printStackTrace();
}
return CompletableFuture.completedFuture(new Integer(status.get()));
}
// Method that will be invoked via RPC from the front end to remove an item
public CompletableFuture<Integer> removeItem(String itemToRemove) {
AtomicInteger status = new AtomicInteger(-1);
try {
ReliableHashMap<String, String> votesMap = stateManager
.<String, String> getOrAddReliableHashMapAsync(MAP_NAME).get();
Transaction tx = stateManager.createTransaction();
votesMap.removeAsync(tx, itemToRemove).get();
tx.commitAsync().get();
tx.close();
status.set(1);
} catch (Exception e) {
e.printStackTrace();
}
return CompletableFuture.completedFuture(new Integer(status.get()));
}
}
Elkészült a kezelőfelületi állapotmentes szolgáltatás és a háttérszolgáltatás váza.
Az alkalmazás kommunikációs interfészének létrehozása
A következő lépés az előtérbeli állapot nélküli szolgáltatás és a háttérszolgáltatás csatlakoztatása. Mindkét szolgáltatás a VotingRPC nevű felületet használja, amely meghatározza a szavazóalkalmazás műveleteit. Ezt az interfészt a kezelőfelület és a háttérszolgáltatás is implementálja, hogy lehetővé váljanak a távoli eljáráshívások (RPC) a két szolgáltatás között. Sajnos az Eclipse nem támogatja a Gradle-alprojektek hozzáadását, ezért a felületet tartalmazó csomagot manuálisan kell hozzáadni.
Kattintson a jobb gombbal a Szavazás projektre a Csomagkezelőben, és válassza az Új>mappa lehetőséget. A mappának adja a VotingRPC/src/rpcmethods nevet.
Hozzon létre egy fájlt a Voting/VotingRPC/src/rpcmethods területen VotingRPC.java néven, és illessze be az alábbiakat a VotingRPC.java fájlba.
package rpcmethods; import java.util.ArrayList; import java.util.concurrent.CompletableFuture; import java.util.List; import java.util.HashMap; import microsoft.servicefabric.services.remoting.Service; public interface VotingRPC extends Service { CompletableFuture<HashMap<String, String>> getList(); CompletableFuture<Integer> addItem(String itemToAdd); CompletableFuture<Integer> removeItem(String itemToRemove); }Hozzon létre egy build.gradle nevű üres fájlt a Voting/VotingRPC könyvtárban, és illessze be a következőket. Ezzel a Gradle-fájllal állítható össze és hozható létre a .jar-fájl, amelyet más szolgáltatások importálnak.
apply plugin: 'java' apply plugin: 'eclipse' sourceSets { main { java.srcDirs = ['src'] output.classesDir = 'out/classes' resources { srcDirs = ['src'] } } } clean.doFirst { delete "${projectDir}/out" delete "${projectDir}/VotingRPC.jar" } repositories { mavenCentral() } dependencies { compile ('com.microsoft.servicefabric:sf-actors:1.0.0') } jar { from configurations.compile.collect { (it.isDirectory() && !it.getName().contains("native")) ? it : zipTree(it)} manifest { attributes( 'Main-Class': 'rpcmethods.VotingRPC') baseName "VotingRPC" destinationDir = file('./') } exclude 'META-INF/*.RSA', 'META-INF/*.SF','META-INF/*.DSA' } defaultTasks 'clean', 'jar'A Voting/settings.gradle fájlban adjon hozzá egy sort, amelyben szerepel a build újonnan létrehozott projektje.
include ':VotingRPC'A Voting/VotingWeb/src/statelessservice/HttpCommunicationListener.java fájlban a megjegyzésblokkot cserélje a következőre.
server.createContext("/getStatelessList", new HttpHandler() { @Override public void handle(HttpExchange t) { try { t.sendResponseHeaders(STATUS_OK,0); OutputStream os = t.getResponseBody(); HashMap<String,String> list = ServiceProxyBase.create(VotingRPC.class, new URI("fabric:/VotingApplication/VotingDataService"), partitionKey, TargetReplicaSelector.DEFAULT, "").getList().get(); String json = new Gson().toJson(list); os.write(json.getBytes(ENCODING)); os.close(); } catch (Exception e) { logger.log(Level.WARNING, null, e); } } }); server.createContext("/removeItem", new HttpHandler() { @Override public void handle(HttpExchange t) { try { OutputStream os = t.getResponseBody(); URI r = t.getRequestURI(); Map<String, String> params = queryToMap(r.getQuery()); String itemToRemove = params.get("item"); Integer num = ServiceProxyBase.create(VotingRPC.class, new URI("fabric:/VotingApplication/VotingDataService"), partitionKey, TargetReplicaSelector.DEFAULT, "").removeItem(itemToRemove).get(); if (num != 1) { t.sendResponseHeaders(STATUS_ERROR, 0); } else { t.sendResponseHeaders(STATUS_OK,0); } String json = new Gson().toJson(num); os.write(json.getBytes(ENCODING)); os.close(); } catch (Exception e) { logger.log(Level.WARNING, null, e); } } }); server.createContext("/addItem", new HttpHandler() { @Override public void handle(HttpExchange t) { try { URI r = t.getRequestURI(); Map<String, String> params = queryToMap(r.getQuery()); String itemToAdd = params.get("item"); OutputStream os = t.getResponseBody(); Integer num = ServiceProxyBase.create(VotingRPC.class, new URI("fabric:/VotingApplication/VotingDataService"), partitionKey, TargetReplicaSelector.DEFAULT, "").addItem(itemToAdd).get(); if (num != 1) { t.sendResponseHeaders(STATUS_ERROR, 0); } else { t.sendResponseHeaders(STATUS_OK,0); } String json = new Gson().toJson(num); os.write(json.getBytes(ENCODING)); os.close(); } catch (Exception e) { logger.log(Level.WARNING, null, e); } } });Vegye fel a megfelelő importálási utasítást a Voting/VotingWeb/src/statelessservice/HttpCommunicationListener.java fájl elején.
import rpcmethods.VotingRPC;
Ezen a ponton kész a kezelőfelület, a háttérszolgáltatás és az RPC-interfészek működése. A következő feladat a Gradle-szkriptek megfelelő konfigurálása a Service Fabric-fürtön való üzembe helyezés előtt.
A mintául szolgáló szavazóalkalmazás bemutatása
A szavazóalkalmazás két szolgáltatásból áll:
- Webes kezelőfelületi szolgáltatás (VotingWeb) – Olyan webes kezelőfelületi Java-szolgáltatás, amely kiszolgálja a weboldalt, és API-kat biztosít a háttérszolgáltatással folytatott kommunikációhoz.
- Háttérszolgáltatás (VotingDataService) – Olyan webes Java-szolgáltatás, amely meghatározza a távoli eljáráshívások (RPC) révén a szavazatok megőrzésére meghívott metódusokat.
Amikor végrehajt egy műveletet az alkalmazásban (elem hozzáadása, szavazás, elem eltávolítása), az alábbi események történnek:
A JavaScript HTTP-kérésként elküldi a megfelelő kérést a webes API-nak a webes kezelőfelületi szolgáltatásban.
A webes kezelőfelületi szolgáltatás a Service Fabric beépített Szolgáltatás távelérésének lehetővé tétele funkciójával megkeresi és továbbítja a kérést a háttérszolgáltatásnak.
A háttérszolgáltatás az eredményeket egy megbízható szótárban tároló metódusokat határoz meg. Ennek a megbízható szótárnak a tartalmát a rendszer több csomóponton replikálja, és megőrzi a lemezen. Az alkalmazás összes adata a fürtön tárolódik.
Gradle-szkriptek konfigurálása
Ebben a szakaszban a projekthez tartozó Gradle-szkriptek konfigurálása történik meg.
Cserélje le a Voting/build.gradle fájl tartalmát az alábbiakra.
apply plugin: 'java' apply plugin: 'eclipse' subprojects { apply plugin: 'java' } defaultTasks 'clean', 'jar', 'copyDeps'Cserélje le a Voting/VotingWeb/build.gradle fájl tartalmát az alábbiakra.
apply plugin: 'java' apply plugin: 'eclipse' sourceSets { main { java.srcDirs = ['src'] output.classesDir = 'out/classes' resources { srcDirs = ['src'] } } } clean.doFirst { delete "${projectDir}/../lib" delete "${projectDir}/out" delete "${projectDir}/../VotingApplication/VotingWebPkg/Code/lib" delete "${projectDir}/../VotingApplication/VotingWebPkg/Code/VotingWeb.jar" } repositories { mavenCentral() } dependencies { compile ('com.microsoft.servicefabric:sf-actors:1.0.0-preview1') compile project(':VotingRPC') } task explodeDeps(type: Copy, dependsOn:configurations.compile) { task -> configurations.compile.filter {!it.toString().contains("native")}.each{ from it } configurations.compile.filter {it.toString().contains("native")}.each{ from zipTree(it) } into "../lib/" include "lib*.so", "*.jar" } task copyDeps<< { copy { from("../lib/") into("../VotingApplication/VotingWebPkg/Code/lib") include('lib*.so') } } compileJava.dependsOn(explodeDeps) jar { from configurations.compile.collect {(it.isDirectory() && !it.getName().contains("native")) ? it : zipTree(it)} manifest { attributes( 'Main-Class': 'statelessservice.VotingWebServiceHost') baseName "VotingWeb" destinationDir = file('../VotingApplication/VotingWebPkg/Code/') } exclude 'META-INF/*.RSA', 'META-INF/*.SF','META-INF/*.DSA' } defaultTasks 'clean', 'jar', 'copyDeps'Cserélje le a Voting/VotingDataService/build.gradle fájl tartalmát.
apply plugin: 'java' apply plugin: 'eclipse' sourceSets { main { java.srcDirs = ['src'] output.classesDir = 'out/classes' resources { srcDirs = ['src'] } } } clean.doFirst { delete "${projectDir}/../lib" delete "${projectDir}/out" delete "${projectDir}/../VotingApplication/VotingDataServicePkg/Code/lib" delete "${projectDir}/../VotingApplication/VotingDataServicePkg/Code/VotingDataService.jar" } repositories { mavenCentral() } dependencies { compile ('com.microsoft.servicefabric:sf-actors:1.0.0-preview1') compile project(':VotingRPC') } task explodeDeps(type: Copy, dependsOn:configurations.compile) { task -> configurations.compile.filter {!it.toString().contains("native")}.each{ from it } configurations.compile.filter {it.toString().contains("native")}.each{ from zipTree(it) } into "../lib/" include "lib*.so", "*.jar" } compileJava.dependsOn(explodeDeps) task copyDeps<< { copy { from("../lib/") into("../VotingApplication/VotingDataServicePkg/Code/lib") include('lib*.so') } } jar { from configurations.compile.collect { (it.isDirectory() && !it.getName().contains("native")) ? it : zipTree(it)} manifest { attributes('Main-Class': 'statefulservice.VotingDataServiceHost') baseName "VotingDataService" destinationDir = file('../VotingApplication/VotingDataServicePkg/Code/') } exclude 'META-INF/*.RSA', 'META-INF/*.SF','META-INF/*.DSA' } defaultTasks 'clean', 'jar', 'copyDeps'
Alkalmazás üzembe helyezése helyi fürtön
Ezen a ponton az alkalmazás készen áll egy helyi Service Fabric-fürtön való üzembe helyezésre.
Kattintson a jobb gombbal a Szavazás projektre a Csomagkezelőben, és válassza a Service Fabric>buildalkalmazás lehetőséget az alkalmazás létrehozásához.
Futtassa a helyi Service Fabric-fürtöt. Ez a lépés a fejlesztési környezettől (Mac vagy Linux) függ.
Ha Mac gépet használ, a helyi fürtöt az alábbi paranccsal futtathatja: cserélje le a -v paraméterben átadott parancsot a saját munkaterületére.
docker run -itd -p 19080:19080 -p 8080:8080 -p --name sfonebox mcr.microsoft.com/service-fabric/onebox:latestRészletesebb útmutatást az OS X beállítási útmutatójában talál.
Ha Linux gépen végzi a futtatást, az alábbi paranccsal indíthatja el a helyi fürtöt:
sudo /opt/microsoft/sdk/servicefabric/common/clustersetup/devclustersetup.shTovábbi részletes útmutatást a Linux telepítési útmutatójában talál.
Az Eclipse csomagkezelőjében kattintson a jobb gombbal a Szavazás projektre, és válassza a Service FabricPublish Application (Service Fabric-közzétételi> alkalmazás) lehetőséget.
Az Alkalmazás közzététele ablakban válassza a Local.json elemet a legördülő listában, majd válassza a Közzététel lehetőséget.
Lépjen a webböngészőjébe, és nyissa meg a http://localhost:8080 címet, ahol megtekintheti a helyi Service Fabric-fürtön futó alkalmazását.
Következő lépések
Az oktatóanyag jelen részében megismerkedhetett a következőkkel:
- Java-szolgáltatás létrehozása állapotalapú megbízható szolgáltatásként
- Java-szolgáltatás létrehozása állapot nélküli webszolgáltatásként
- Java-interfész felvétele a távoli eljáráshívások (RPC) szolgáltatások közötti kezeléséhez
- A Gradle-szkriptek konfigurálása
- Az alkalmazás összeállítása és üzembe helyezése a helyi Service Fabric-fürtön
Folytassa a következő oktatóanyaggal: