不收费的网站_石家庄新闻头条新闻最新今天_外贸订单怎样去寻找_网络营销公司有哪些公司

前言

之前我写的springboot项目中的opc ua连接配置信息都是写在springboot项目的yml文件里，每次修改连接配置都需要重启springboot服务。而且在大多数时候，我部署项目的时候，还不知道opc ua的连接信息，部署完毕后，才从相关的技术人员哪里拿到opc ua的连接信息，索引我想，要是能够设置成通过网页配置的可能会更好，说干就干，下面是实现教程!

快速开始

引入Maven依赖

在pom.xml文件配置里引入milo的jar依赖，配置如下：

        <!-- milo opc ua --><dependency><groupId>org.eclipse.milo</groupId><artifactId>sdk-client</artifactId><version>0.6.11</version></dependency>

编写java代码

controller层代码


import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.coalface.modules.communicate.entity.OpcUaCommunicate;
import org.springblade.coalface.modules.communicate.service.CommunicateService;
import org.springblade.coalface.modules.opcua.service.OpcUaTemplate;
import org.springblade.core.tool.api.R;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;import javax.validation.Valid;
import java.util.regex.Matcher;
import java.util.regex.Pattern;@RestController
@Api(tags = "通讯配置")
@RequestMapping("/communicate/config")
@AllArgsConstructor
@Slf4j
public class CommunicateController {private final OpcUaTemplate opcUaTemplate;private final CommunicateService communicateService;private static final String OPC_TCP_REGEX = "^opc.tcp://(\\d{1,3}\\.){3}\\d{1,3}:(\\d{1,5})$";@GetMapping("/opcua")@ApiOperation(value = "获取opc ua配置")public R<OpcUaCommunicate> getOpcUaConfig() {return R.data(communicateService.getOpcUaCommunicate());}@PostMapping("/opcua/update")@ApiOperation(value = "修改opc ua配置")@Transactional(rollbackFor = Exception.class)public R<String> updateOpcUaConfig(@RequestBody @Valid OpcUaCommunicate opcUaCommunicate) {if(!isValidOpcTcp(opcUaCommunicate.getEndPointUrl())){return R.fail("opu ua endPointUrl格式错误");}opcUaTemplate.updateConfig(opcUaCommunicate);communicateService.saveOpcUaCommunicate(opcUaCommunicate);return R.success();}// 检验URL格式的方法public  boolean isValidOpcTcp(String url) {return isValidRegex(url, OPC_TCP_REGEX);}public  boolean isValidRegex(String url, String regex) {if (url == null) {return false;}Pattern URL_PATTERN = Pattern.compile(regex);Matcher matcher = URL_PATTERN.matcher(url);if(matcher.matches()){int startIndex = url.indexOf("//") + 2; // 找到"//"的位置并加2，跳过"//"int endIndex = url.indexOf(":", startIndex);String ip=url.substring(startIndex, endIndex);String[] parts = ip.split("\\.");for (String part : parts) {int num = Integer.parseInt(part);if (num < 0 || num > 255) {return false;}}String port=url.substring(endIndex+1);System.out.println(port);int portNum = Integer.parseInt(port);return portNum >= 0 && portNum <= 65535;}return false;}}

接口参数类

代码如下：

package org.springblade.coalface.modules.communicate.entity;import lombok.Data;import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;@Data
public class OpcUaCommunicate {@NotNullprivate Boolean enabled;@NotBlankprivate String endPointUrl;private String username;private String password;
}

service服务类

CommunicateService	类，主要是为了将	opc u	a的连接配置信息，保存或者修改到`mongodb`数据库中，并从数据库中查询配置的方法。