微服务架构 -动手实践 SOA

在本章中，我们将使用 SOA 架构开发基于 CRUD 的应用程序。在后续章节中，我们将把这项服务分解为微服务，并了解 SOA 和微服务架构之间的基本区别。

系统配置和设置

在本节中，我们将构建一个示例 CRUD 应用程序，每当我们调用我们的服务时，它将返回 JSON 对象作为响应。我们将使用 Jersey 框架来开发相同的应用程序。以下是设置本地系统环境的步骤。

开发 CRUD 应用程序

步骤 1 − 我们将使用 NetBeans 作为开发 IDE。请在 NetBeans 官方网站 https://netbeans.org/downloads/ 下载并安装最新版本。

步骤 2 − 打开您的 NetBeans IDE。转到"文件 -> 新建项目"。弹出以下屏幕截图。选择"Maven"作为类别，选择"ArchType 中的项目"作为项目，然后单击下一步。

这将下载创建您的第一个 Maven 项目和 RESTful Web 服务所需的所有 jar 文件。

步骤 3 − 在上一步中点击下一步按钮后，将出现以下屏幕截图。在这里，您必须指定 Maven Archetype。

在搜索框中，搜索"Jersey-archType-Webapp(2.16)"并选中"显示旧版本"复选框。

步骤 4 − 选择相同内容后，您将被重定向到以下屏幕。从列表中选择所需的 jar，然后单击"下一步"继续。

步骤 5 − 在此步骤中，您需要提供项目的名称及其组 ID 以及包详细信息。提供所有这些信息后，点击"完成"继续。

步骤 6 − 您已完成工作区设置。项目目录将如下所示。

查看"依赖项"文件夹，您会发现 Maven 已自动下载此项目所需的所有 jar 文件。

步骤 7 − 您的工作区已设置完毕，您可以开始编码。继续创建四个类和包，如以下屏幕截图所示。您会发现 MyResource.java 已由 Maven 创建，因为 Maven 足够智能，可以检测到您将要构建自己的 Web 服务。

步骤 8 − 完成上述步骤后，我们将按如下方式构建我们的 POJO 类，即 UserProfile.java。

package com.tutorialspoint.userprofile.Model;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement
public class UserProfile {
   private long ProId;
   private String FName;
   private String LName;
   private String Add;
   public UserProfile(){}
   
   public UserProfile(long Proid, String Fname, String Lname,String Add) {
      this.ProId = Proid;
      this.FName = Fname;
      this.LName = Lname;
      this.Add = Add;
   }
   public long getProId() {
      return ProId;
   }
   public void setProId(long ProId) {
      this.ProId = ProId;
   }
   public String getFName() {
      return FName;
   }
   public void setFName(String FName) {
      this.FName = FName;
   }
   public String getLName() {
      return LName;
   }
   public void setLName(String LName) {
      this.LName = LName;
   }
   public String getAdd() {
      return Add;
   }
   public void setAdd(String Add) {
      this.Add = Add;
   }
}

步骤 9 − 现在我们将创建数据库类。由于这是学习材料的一部分，我们不会使用任何 DB 作为数据库。我们将使用内置 Java 内存作为临时内存。正如您在以下代码集中看到的，我们将使用 MAP 作为数据库。我们执行的所有 Web 服务操作都将在类中定义的这个 MAP 上进行。

package com.tutorialspoint.userprofile.DAO;

import com.tutorialspoint.userprofile.Model.UserProfile;

import java.util.HashMap;
import java.util.Map;

public class DatabaseClass {
   private static Map<Long,UserProfile> messages = new HashMap<Long,UserProfile>();
   public static Map<Long,UserProfile> getUsers() {
      return messages; 
      // Each time this method will return entire map as an instance of database
   }
}

步骤 10 − 现在让我们构建我们的服务类。继续将以下代码集复制粘贴到"ProfileService.java"类中。我们将在这个类中声明所有要向外部世界公开的 Web 服务方法。我们需要创建一个 DatabaseClass 的引用，以便可以在此类中访问我们的临时数据库。

package com.tutorialspoint.userprofile.service;

import com.tutorialspoint.userprofile.DAO.DatabaseClass;
import com.tutorialspoint.userprofile.Model.UserProfile;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

public class ProfileService {
   private Map<Long,UserProfile> Userprofiles = DatabaseClass.getUsers();
   
   // 创建一些预定义配置文件并将其填充到地图中
   public ProfileService() {
      UserProfile m1 = new UserProfile(1L,"Tutorials1","Point1","TutorialsPoint.com");
      UserProfile m2 = new UserProfile(2L,"Tutorials2","Point2","TutorialsPoint.com2");
      UserProfile m3 = new UserProfile(3L,"Tutorials3","Point3","TutorialsPoint.com3");
      UserProfile m4 = new UserProfile(4L,"Tutorials4","Point4","TutorialsPoint.com4");
      
      Userprofiles.put(1L, m1);
      Userprofiles.put(2L, m2);
      Userprofiles.put(1L, m3);
      Userprofiles.put(2L, m4);
   }
   
   //Method to fetch all profile
   public List<UserProfile> getAllProfile() {
      List<UserProfile> list = new ArrayList<UserProfile>(Userprofiles.values());
      return list;
   }  // Method to fetch only one profile depending on the ID provided
   
   public UserProfile getProfile(long id) {
      return Userprofiles.get(id);
   }  //Method to add profile
   
   public UserProfile addProfile(UserProfile UserProfile) {
      UserProfile.setProId(Userprofiles.size()+1);
      Userprofiles.put(UserProfile.getProId(), UserProfile);
      return UserProfile;
   }  //method to update Profile

   public UserProfile UpdateProfile(UserProfile UserProfile) {
      if(UserProfile.getProId()<=0) { 
         return null;
      } else { 
         Userprofiles.put(UserProfile.getProId(), UserProfile);
         return UserProfile;
      }
   } //method to delete profile
   
   public void RemoveProfile(long Id) {
      Userprofiles.remove(Id);
   }
}

步骤 11 − 在此步骤中，我们将创建与 URL 链接的资源类，并调用相应的服务。

package com.tutorialspoint.userprofile.Resource;

import com.tutorialspoint.userprofile.Model.UserProfile;
import com.tutorialspoint.userprofile.service.ProfileService;

import java.util.List;
import javax.ws.rs.Consumes;
import javax.ws.rs.DELETE;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.PUT;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

@Path("/Profile")
@Consumes(MediaType.APPLICATION_XML)
@Produces(MediaType.APPLICATION_XML)

public class ProfileResource {
   ProfileService messageService = new ProfileService();
   
   @GET
   public List<UserProfile> getProfile() {
      return messageService.getAllProfile();
   }

   @GET
   @Path("/{ProID}")
   public UserProfile getProfile(@PathParam("ProID")long Id) {
      return messageService.getProfile(Id);
   }

   @POST
   public UserProfile addProfile(UserProfile profile) {
      return messageService.addProfile(profile);
   }

   @PUT
   @Path("/{proID}")
   public UserProfile UpdateProfile(@PathParam("proID")long Id,UserProfile UserProfile) {
      UserProfile.setProId(Id);
      return messageService.UpdateProfile(UserProfile);
   }
   
   @DELETE
   @Path("/{ProID}")
   public void deleteProfile(@PathParam("ProID")long Id) {
      messageService.RemoveProfile(Id);
   }
}

步骤 12 − 干净地构建项目并运行它。如果一切顺利，那么您应该在浏览器中访问 http://localhost:8080/UserProfile/webapi/Profile" URL 时获得以下输出。

您可以看到使用 XML 表示填充了不同的条目。