2. 程式人生 > 實用技巧 >Java NIO（四）開發基於幀的ping-pong伺服器

Java NIO（四）開發基於幀的ping-pong伺服器

阿新 • • 發佈：2020-11-12

專案講解

具體功能如何實現

需要到的技術（純後端開發）

josn+spring boot+mybatis puls+mysql資料庫

什麼是josn：

JSON(JavaScript Object Notation) 是一種輕量級的資料交換格式。易於人閱讀和編寫。同時也易於機器解析和生成。

翻譯人能聽懂的話就是 我從後端傳到前端的資料能顯示出來前端需要的格式

什麼是spring boot：

從最根本上來講，Spring Boot就是一些庫的集合，它能夠被任意專案的構建系統所使用。

翻譯成人能聽懂的話就是spring boot 就是一個框架

特點： 自動裝配，控制反轉

什麼是Mybatis：

MyBatis 是一款優秀的持久層框架，它支援自定義 SQL、儲存過程以及高階對映。
MyBatis 免除了幾乎所有的 JDBC 程式碼以及設定引數和獲取結果集的工作。
MyBatis 可以通過簡單的 XML 或註解來配置和對映原始型別、介面和 Java POJO（Plain Old Java Objects，普通老式 Java 物件）為資料庫中的記錄。

翻譯成人能聽懂的話就是Mybatis就是一個高階的JDBC

在翻譯就是java語言怎麼和資料庫連線

這就是Mybatis！

什麼是mysql資料庫：

不想說...

一個java web專案主要分為一下三層

  1. contorller
  2. servise
  3. dao

流程圖：

controller層

  • 最重要的一點就是提供api介面與前端互動

以下是我擷取的片段程式碼（controller層）具體的一個前端互動實現

@Api(tags = "裝置臺賬-裝置列表")
@RestController
@RequestMapping("/ledger")
@Slf4j
public class LedgerController {
@Autowired
private ApparatusInfoService apparatusInfoService;

@Autowired
private SysDdictionariesService sysDdictionariesService;

@Autowired
private ApparatusProcessService apparatusProcessService;

@Autowired
private ApparatusStatsService apparatusStatsService;
@SysLog("建立裝置")
@ApiOperation("建立")
@PostMapping("/apparatus")
@RequiresPermissions("ledger:apparatusinfo:save")
public R create(@RequestBody ApparatusInfoDTO apparatusInfoDTO) {
    String categoryName = apparatusInfoDTO.getCategoryName();
    if (StringUtils.isEmpty(categoryName) ||
            StringUtils.isEmpty(apparatusInfoDTO.getSn()) ||
            StringUtils.isEmpty(apparatusInfoDTO.getUsestate())) {
        log.error("faield to ledger create, 必要引數為空");
        return R.ok("建立失敗,請填寫完整資訊");
    }
    boolean b = apparatusInfoService.createCheckSn(apparatusInfoDTO.getSn());
    if (!b) {
        log.error("faield to ledger create, 裝置編碼已存在");
        return R.error("裝置編碼已存在");
    }
    JSONObject infoTemplate = null;
    String statsInfo = null;
    try {
        statsInfo = JsonUtils.getStrToJson(categoryName, "realtime");
    } catch (Exception e) {
        log.error("faield to ledger create statsInfo", e);
        return R.error("建立失敗");
    }
    ApparatusStatsEntity status = new ApparatusStatsEntity();

    String infoString = apparatusInfoDTO.getInfoString();
    if (StringUtils.isEmpty(infoString)) {
        try {
            infoTemplate = apparatusInfoService.getInfoTemplate(categoryName, "static");

            apparatusInfoDTO.setInfo(infoTemplate);
        } catch (Exception e) {
            log.error("faield to ledger create infoTemplate", e);
            return R.error("建立失敗");
        }
    } else {
        JSONObject info = JSONObject.parseObject(infoString);
        apparatusInfoDTO.setInfo(info);
    }
    SysUserEntity user = (SysUserEntity) SecurityUtils.getSubject().getPrincipal();
    apparatusInfoDTO.setCreatetime(new Date());
    JSONObject statusTemplate = (JSONObject) JSONObject.parse(statsInfo);
    apparatusInfoDTO.setStatusthreshold(statusTemplate);
    apparatusInfoDTO.setCreateuser(user.getUsername());
    ApparatusInfoEntity apparatusInfo = ApparatusInfoDTO.getInfoEntity(apparatusInfoDTO);
    try {
        apparatusInfoService.save(apparatusInfo);
        Long infoid = apparatusInfoService.selectInfoid(apparatusInfoDTO.getSn());
        status.setInfoid(infoid);
        status.setInfo(statsInfo);
        status.setCreatetime(new Date());
        status.setCreateuser(user.getUsername());
        apparatusStatsService.createStatus(status);
        log.info("ledger create, infoEntity:{}, apparatusInfoDTO:{}", apparatusInfo, apparatusInfoDTO);
        return R.ok("建立成功");
    } catch (Exception e) {
        log.error("faield to ledger create createStatus", e);
        return R.error("建立失敗");
     }
   }
}

//Class R 返回狀態碼與資訊
public class R extends HashMap<String, Object> {
private static final long serialVersionUID = 1L;

public R() {
	put("code", 0);
	put("msg", "success");
}

public static R error() {
	return error(HttpStatus.SC_INTERNAL_SERVER_ERROR, "未知異常，請聯絡管理員");
}

public static R error(String msg) {
	return error(HttpStatus.SC_INTERNAL_SERVER_ERROR, msg);
}

public static R error(int code, String msg) {
	R r = new R();
	r.put("code", code);
	r.put("msg", msg);
	return r;
}

public static R ok(String msg) {
	R r = new R();
	r.put("msg", msg);
	return r;
}

public static R ok(Map<String, Object> map) {
	R r = new R();
	r.putAll(map);
	return r;
}

public static R ok() {
	return new R();
}

public R put(String key, Object value) {
	super.put(key, value);
	return this;
}

}

程式開頭 有這4個註解

註解：spring 4.0特性 幫助開發

分析一下這4個註解

@Api(tags = "裝置臺賬-裝置列表")這是個swagerr註解
表示標識這個類是swagger的資源


@RestController

@RestController註解是@Controller和@ResponseBody的合集,表示這是個控制器bean,並且是將函式的返回值直 接填入HTTP響應體中,是REST風格的控制器。

翻譯一下就是 後臺返回資料用這個

@RequestMapping(/ledger)

@RequestMapping：提供路由資訊，負責URL到Controller中的具體函式的對映。

就是相當於返回對映到這個url下 http://localhost ：8080/xxx/ledger

@Slf4j

log的註解 列印日誌到哪裡的註解 (java程式碼規範有寫：log可以設定級別，可以控制輸出到哪裡，容易區分是在程式碼的什麼地方列印的，而System.out.print則不行。而且，System.out.print的速度很慢。所以，除非是有意的，否則，都要用log。至少在提交到svn之前把System.out.print換成log。--來源gittab)

再往下看程式碼

@Autowired

@Autowired 註釋，它可以對類成員變數、方法及建構函式進行標註，完成自動裝配的工作。 通過 @Autowired的使用來消除 set ，get方法

翻譯一下就是 把你的Controller與service連線起來

再看

點進來

就進到了你的Service
extends繼承
IService<> 一個方法
ApparatusStatsEntity 這個是其他類中的class程式碼具體就是把資料庫有的欄位定義出來

Entity中具體程式碼

package cn.galaiot.modules.ledger.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;

import java.io.Serializable;
import java.util.Date;

/**
	* @author zhangtong
	* @date 2020-09-04 14:06:29
 */
@Data  //註解 有了這個就不需要get set方法了
@TableName(value = "apparatus_process", autoResultMap = true)
public class ApparatusProcessEntity implements Serializable {
private static final long serialVersionUID = 1L;
/**
     * 主鍵id
 */
@TableId
private Long id;
/**
     * 裝置id
 */
private Long infoid;
/**
 * 操作時間
 */
@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
private Date operationtime;
/**
 * 管理內容
 */
private String managecontent;
/**
 * 實施方式
 */
private String implement;
/**
 * 實施方
 */
private String executor;
/**
 * 費用
 */
private Double expense;
;
/**
 * 完好待用時間
 */
private Long readyforusetime;
/**
 * 運轉時間
 */
private Long runningtime;
/**
 * 故障時間
 */
private Long faulttime;
/**
 *正常保養時間
 */
private Long normalmaintenancetime;
/**
 * 維保時間
 */
private String maintenancetime;
/**
 * 備註
 */
private String remark;
/**
 * 值班人
 */
private String inspector;
/**
 * 開始維保時間
 */
@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
private Date starttime;
/**
 * 維保結束時間
 */
@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd")
private Date endtime;
/**
 * 責任人
 */
private String responsible;
/**
 * 任務描述
 */
private String description;
/**
 * 配套裝置
 */
private String equipment;
/**
 * 詳細資訊
 */
@TableField(typeHandler = FastjsonTypeHandler.class)
private String info;
/**
 * 建立時間
 */
private Date createtime;
/**
 * 建立人
 */
private String createuser;
/**
 * 修改時間
 */
private Date updatetime;
/**
 * 修改人
 */
private String updateuser;
/**
 * 裝置狀態, -1表示刪除, 0表示正常
 */
private Integer status;
}

暫且不談Entity包是個什麼東西

繼續上面程式碼

又是4個註解

@SysLog
與上面 @Slf4j對應 寫出log列印到哪裡

@ApiOperation
首先@ApiOperation註解不是Spring自帶的，它是是swagger裡的
註解@ApiOperation是用來構建Api文件的
@ApiOperation(value = “介面說明”, httpMethod = “介面請求方式”, response =
“介面返回引數型別”, notes = “介面釋出說明”；其他引數可參考原始碼；

提到swagger不得不提到RESTful風格

RESTFUL是一種網路應用程式的設計風格和開發方式，基於HTTP，可以使用XML格式定義或JSON格式定義。RESTFUL適用於移動網際網路廠商作為業務使能介面的場景，實現第三方OTT呼叫行動網路資源的功能，動作型別為新增、變更、刪除所呼叫資源。

一個@ApiOperation的通用寫法 下面是舉例

@ApiOperation(value="建立使用者", notes="根據User物件建立使用者")
@ApiImplicitParam(name = "user", value = "使用者詳細實體user", required = true, dataType = "User")
@RequestMapping(value="", method=RequestMethod.POST)
public String postUser(@RequestBody User user) {
    users.put(user.getId(), user);
    return "success";
}

下一個的@PostMapping註解

  1. @PostMapping
  2. @PutMapping
  3. @DeleteMapping
  4. @PatchMapping
  5. @GetMapping

為什麼這麼寫：

@PostMapping("/apparatus")

這裡的和Swagger上顯示的一樣就行

什麼是@PostMapping:

對映一個POST請求 處理post請求

等價於@RequestMapping(value = "/user/login",method = RequestMethod.POST)

Spring官方文件說：

@GetMapping是一個組合註解，是@RequestMapping(method = RequestMethod.GET)的縮寫。該註解將HTTP Get 對映到 特定的處理方法上。

@PostMapping 是一個組合註解，是@RequestMapping(method = RequestMethod.POST)的縮寫。該註解將HTTP Post 對映到 特定的處理方法上。

到public R create(@RequestBody ApparatusInfoDTO apparatusInfoDTO)

@ResponseBody：表示該方法的返回結果直接寫入HTTP response body中，一般在非同步獲取資料時使用，用於構建RESTful的api。在使用@RequestMapping後，返回值通常解析為跳轉路徑，加上@responsebody後返回結果不會被解析為跳轉路徑，而是直接寫入HTTP response body中。

比如非同步獲取json資料，加上@responsebody後，會直接返回json資料。該註解一般會配合@RequestMapping一起使用。

點選ApparatusInfoDTO 跳轉到public class ApparatusInfoDTO extends ApparatusInfoEntity

寫到這裡可以緩一緩了 不要急來到service層

至於為什麼 就因為這個程式裡的第一行程式碼~

HashMap<String, Object> date = apparatusInfoService.getAll(params);
分析程式碼
HashMap<String,Object> date 定義一個hashmap集合 名字為 date
apparatusInfoService.getAll(params)
apparatusInfoService.得到所有 引數

這就是重點了 因為apparatusInfoService在這！

這裡實現了Controller層互動service層。

相關推薦

Java NIO（四）開發基於幀的ping-pong伺服器

TCP有個特性是粘包，也就是一個包後面可能跟著下一個包的部分或者全部資料，幀格式就是用來解決粘包問題的。幀格式一般都是在包的前面增加一個包頭，包頭裡的一個欄位會儲存包的大小。所以基於幀的伺服器的每條連線的

帶你從0到1正確學Java（四）開發第一個Java程式——HelloWorld

開發第一個Java程式：HelloWorld 學習任何語言，第一個程式都是hello world。 Hello World是一個最著名的程式。對每一位程式設計師來說，這個程式幾乎是每一門程式語言中的第一個示例程式。

Java NIO（三）非阻塞的連線操作

非同步連線需要做以下操作： 設定socket為非阻塞模式 註冊OP_CONNECT事件 OP_CONNECT事件發生時，呼叫SocketChannel的finishConnection

java爬蟲（四）利用Jsoup獲取需要登陸的網站中的內容（無驗證碼的登入）

一、實現原理 登入之後進行資料分析，精確抓取資料。根據上篇文章的程式碼，我們不僅獲取了cookies，還獲取了登入之後返回的網頁原始碼，此時有如下幾種種情況：（1）若我們所需的資料就在登入之後返回的原始碼裡面，

Spring學習總結（四）：基於XML的Bean裝配中常見操作

技術標籤：Spring學習javaspringbean 一、注入空值和特殊符號 1、注入空值 （1）建立實體類User，提供私有屬性name、age和address，並提供它們的set方法和toString()。

狂神Java SE （四）流程控制

01 使用者互動 Scanner java.util.Scanner Java5的新特性，可以通過Scanner類獲取使用者的輸入。

JAVA篇：Java IO （四） 過濾流、緩衝流、推回輸入流、特殊流

4、過濾流、緩衝流、推回輸入流、特殊流 位元組流中的過濾過濾流FilterInputStream和FilterOutputStream的作用是“為基礎流提供一些額外的功能”。其常見子類包含緩衝流(BufferedInputStream/ BufferedOutputStre

Dataphin核心功能（四）:安全——基於資料許可權分類分級和敏感資料保護，保障企業資料安全

簡介：《資料安全法》的釋出，對企業的資料安全使用和管理提出了更高的要求。Dataphin提供基於資料分級分類和資料脫敏的敏感資料識別和保護能力，助力企業建立合規的資料安全體系，保障企業資料安全。本篇，我們就來

java基礎（四）

1.36 遇到過異常嗎，如何處理？ 在Java中，可以按照如下三個步驟處理異常： 捕獲異常

spring5入門（四）：基於xml配置管理bean，注入特殊字元、外部bean、內部bean、級聯bean

注入null # 方式一：可以在實體類中直接設定為空 private String oname=\"\"; # 方式二：在bean.xml中配置如下

java web開發（四）Servlet

>>> 一動態web技術 開發動態web的技術，常見的有ASP，PHP，JSP和Servlet。基於java的動態web開發，Sun公司提供了Servlet和JSP兩種技術。

Java開發入門之第一階段（四）

技術標籤：Java學習之路java 比較運算子 比較運算子，是兩個資料之間進行比較的運算，運算結果都是布林值true或者false

Java測試開發--Set、Map、List三種集合（四）

1.集合型別主要有3種：set(集）、list(列表）和map(對映)。 2.三者關係 3.Set set介面是Collection介面的一個子介面，是無序的，set去重，也就是說set中不存在兩個這樣的元素a1.equals(a2)結果為true。但是set去

《深入理解Java虛擬機器器》（四）：垃圾收集演演算法以及記憶體分配策略

============== 讀書筆記系列 ============== 接下來我們就要聊到最常見的問題了，垃圾收集演演算法，以及記憶體分配策略。

Hadoop 系列（四）—— Hadoop 開發環境搭建

一、前置條件 Hadoop 的執行依賴 JDK，需要預先安裝，安裝步驟見： Linux 下 JDK 的安裝

Java併發程式設計（四）有序性

Java極客  |  作者  /  鏗然一葉 這是Java極客的第 32 篇原創文章 一、指令重排

Java SE基礎鞏固（四）：集合類

1 集合概述 Java中有很多集合類，例如ArrayList，LinkedList，HashMap，TreeMap等。集合的功能就是容納多個物件，它們就像容器一樣（實際上，直接稱為容器也沒有毛病，C++就是這樣稱呼的），當需要的時候，可以從裡面

使用位運算、值交換等方式反轉java字串（四種方法）

在本文中，我們將向您展示幾種在Java中將String型別的字串字母倒序的幾種方法。

WeChat小程式開發（四）

重新編寫了上一次的那個半成品。 這次程式設計的任務是編寫一個小程式能夠成功實現未註冊使用者進入小程式時的註冊功能，註冊過的使用者進入小程式後可以修改使用者資訊的功能。

Flume基礎（七）：企業開發案例（四）

單資料來源多出口案例(選擇器) 單 Source 多 Channel、Sink 如圖 7-2 所示。 圖 7-2 單 Source 多 Channel、Sink