实际开发中经常会遇到要和其他平台或系统对接的情况，实际操作就是互相调用别人的接口获取或者推送数据，
 
 
当我们调用别人接口推送数据时，需要对方给一个接口地址以及接口的规范文档，规范中要包括接口的明确入参及其格式，和接口返回状态的几种情况，
 
 
调用的后台acion层业务管理层代码：
 
 
 
  
/**
     * 调用XXX市接口推送银行开户信息  
     * ywguid 即为 projectguid
     * @exception/throws [违例类型] [违例说明]
     * @see [类、类#方法、类#成员]
     */
    public void pushToSZOpenAcountApplyinfo(String projectguid) {
        try {
            YzyhEntityServiceImpl yzyhEntityServiceImpl = new YzyhEntityServiceImpl();
            System.out.println("===================引入银行印章流程得实体service" + yzyhEntityServiceImpl);
            YzyhEntity yzyhEntity = yzyhEntityServiceImpl.getYzyhEntityByProjectguid(projectguid);
            //时间格式化
            SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd 00:00:00");
            if (yzyhEntity != null) {
                RestfulService restfulservice = new RestfulService();
                JSONObject jobparasjson = new JSONObject();
                JSONObject jobjparas = new JSONObject();
                jobparasjson.put("token", "xxx_WebSerivce_**##0601");
                //业务标识
                jobjparas.put("ywguid", projectguid);
                //存款人名称
                jobjparas.put("acctna", StringUtil.isBlank(yzyhEntity.getAcctna()) ? "" : yzyhEntity.getAcctna());
                //证明文件种类
                if (StringUtil.isNotBlank(yzyhEntity.getIdtftp())) {
                    jobjparas.put("idtftp", yzyhEntity.getIdtftp());
                } else {
                    jobjparas.put("idtftp", "M");
                }
                String areacode = "";
                //证明文件编号
                jobjparas.put("idtfno", StringUtil.isBlank(yzyhEntity.getIdtfno()) ? "" : yzyhEntity.getIdtfno());
                //证明文件有效期 
                jobjparas.put("matudt", StringUtil.isBlank(yzyhEntity.getMatudt()) ? "2099-12-30 00:00:00"
                        : sdf2.format(yzyhEntity.getMatudt()));
                //地址
                //                String address = yzyhEntity.get("Ctrl66") + "省（市/区）";
                //                address += yzyhEntity.get("Ctrl67") + "市（区/盟/州）";
                //                address += yzyhEntity.get("Ctrl68") + "县";
                //                address += yzyhEntity.get("Ctrl69") + "乡（镇/街道）";
                //                address += yzyhEntity.get("Ctrl70") + "村（路）";
                //                address += yzyhEntity.get("Ctrl71") + "号";
                //id有效期
                jobjparas.put("lwiddt", StringUtil.isBlank(yzyhEntity.getLwiddt()) ? "2099-12-30 00:00:00"
                        : sdf2.format(yzyhEntity.getLwiddt()));
                //证件编号
                jobjparas.put("lwidno", yzyhEntity.getLwidno());
                //基本账户开户许可核准号
                jobjparas.put("dtittp", "ACO1");
                //代理人证件有效期
                jobjparas.put("pxmudt", StringUtil.isBlank(yzyhEntity.getPxmudt()) ? "2099-12-30 00:00:00"
                        : sdf2.format(yzyhEntity.getPxmudt()));
                //业务代码
                jobjparas.put("qxcode", yzyhEntity.getQxcode());
                jobparasjson.put("params", jobjparas);
                System.out.println("开户申请参数：" + jobparasjson);
                //调用市政上报接口
                String result = restfulservice.getTaskinfo(jobparasjson.toString());
                System.out.println("===============开户申请信息返回值：" + result);
                if (StringUtil.isBlank(result)) {
                    System.out.println("=============开户申请信息推送失败=====================");
                }
                JSONObject jsonresult = (JSONObject) JSONObject.parse(result);
                String custom = jsonresult.getString("custom");
                JSONObject jsoncustom = (JSONObject) JSONObject.parse(custom);
                String code = jsoncustom.getString("code");
                if ("1".equals(code)) {
                    System.out.println("==============开户申请返回结果：" + jsoncustom.getString("text"));
                } else {
                    System.out.println("==============开户申请返回结果：" + jsoncustom.getString("text"));
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            System.out.print(e.toString());
        }
    }
 
 
 
 
 
 
 
所调用的所调用的restful接口，包含http模拟请求代码的service层业务逻辑实施层代码：
 
 
 
  
package com.xxx.xxxxx.yzyhentity.action;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.RequestEntity;
import org.apache.commons.httpclient.methods.StringRequestEntity;

import com.xxx.basic.bizlogic.sysconf.systemparameters.service.FrameConfigService9; 
/**
 * 接口请求
 *  [一句话功能简述]
 *  [功能详细描述]
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public class RestfulService
{

    private static String SZRESTFULURL;

    private static String pushSZzwzxOpenAcountApplyinfo = "szbank/pushSZzwzxOpenAcountApplyinfo";//开户申请推送市政务服务中心商业银行 

    static {
        SZRESTFULURL = new FrameConfigService9().getFrameConfigValue("苏州市restful接口地址");
    }

    /**
     *  开户申请推送市政务服务中心商业银行
     *  [一句话功能简述]
     *  [功能详细描述]
     *  @param param ，为调用别人接口的入参
     *  @return    
     * @exception/throws [违例类型] [违例说明]
     * @see [类、类#方法、类#成员]
     */
    public String getTaskinfo(String param) {
        String url = SZRESTFULURL + pushSZzwzxOpenAcountApplyinfo;
        System.out.println("=============开户申请信息推送地址："+url);
        return sendPost(url, param);
    }
 
    /**
     * http模拟请求
     */
    public String sendPost(String url, String param) {
        try {
            String result = null;
            String loginresturl = url;
            HttpClient httpClient = new HttpClient();
            PostMethod post = new PostMethod(loginresturl);
            HttpMethod method = post;
            System.out.println("=============开户申请信息推送地址："+url);
            if (param != null) {
                RequestEntity se = new StringRequestEntity(param, "application/json", "UTF-8");
                post.setRequestEntity(se);
            }
            try {
                httpClient.executeMethod(method);
                String restresponse = method.getResponseBodyAsString();
                System.out.println("===================restresponse:" + restresponse);
                result=restresponse;
            } catch (Exception e) {
                e.printStackTrace();
                
            } finally {
                post.releaseConnection();
                
            }
            return result;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

}
 
 
 
 
 
 
 
转载于:https://www.cnblogs.com/wmqiang/p/10500663.html

 
 
 
 

因为以前从未用数据库向java接口推送数据，所以为了实现这个demo我是一步一个脚印的踩坑啊！！！
 
此文章的作用以及应用场景：利用数据库主动推送数据,实现前端页面数据实时更新,替换ajax轮询机制。推送的依据是，只要数据库指定的表中数据增加有了变化,数据库会触发触发器然后通过存储过程调用消息推送接口
 
 
 
代码如下：....
 
     
 
----------------------------触发器---------------------------------------
USE [devRep]
GO
/****** Object:  Trigger [dbo].[tr_sm_demo]    Script Date: 2019/9/26 14:06:46 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
-- =============================================


-- Description:	<Insert触发器>
-- =============================================
create TRIGGER [dbo].[tr_sm_demo] 
 
ON [dbo].[demo] 
 
AFTER insert
 
AS 
BEGIN
	declare @id int
 
	set @id = (select id from demo where id=@id)  --如不指定条件查询  会出现 子查询返回的不是一个参数 !<> >>?  乱七八糟的一个错误  就是这里返回必须是一个数据
 
	exec proc_useJPushAPI @id --调用存储过程并传参 如果传入的参数未变则不会触发
 
	SET NOCOUNT ON;
END
 
----------------------------存储过程--------------------------------

USE [devRep]
GO
/****** Object:  StoredProcedure [dbo].[proc_useJPushAPI]    Script Date: 2019/9/26 13:56:19 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
-- =============================================

-- Description:	<调用消息推送接口>
-- =============================================
CREATE procedure [dbo].[proc_useJPushAPI]
	@id varchar(20)		--demo表的id字段
AS
BEGIN
	--创建存储过程里的参数
	declare @url varchar(4000)	--接口路由
	declare @object int			--OLE对象实例
	declare @responseText varchar(4000) --文本
	declare @name varchar(20)
    select @name=name from demo;  --查询demo表为接口传递参数
	set @url = 'http://127.0.0.1:8080/site/recedata?name='+@name ;
	
	print @url
 
	exec sp_OACreate'MSXML2.XMLHTTP',@object out
	exec sp_OAMethod @object,'open',null,'get',@url,'false'
	exec sp_OAMethod @object,'send'
	exec sp_OAMethod @object,'responseText',@responseText output
 
	print @responseText
 
	exec sp_OADestroy @object
 
	SET NOCOUNT ON;
 
END
 
//接收java接口代码 
@RequestMapping(value = "/recedata")
    public String recedata( String name) {
        try {
            System.out.println("sql server 访问啦---");
            return "HELLO";
        } catch (Exception e) {
            logger.info(e.getMessage(),e);
        }
        return null;
    }
 
 
 
第二种写法
 
create table A(keyId int,info1 varchar(20))
go
insert into A values(1,'a')
insert into A values(2,'b')
insert into A values(3,'C')
insert into A values(4,'d')
insert into A values(5,'e')
insert into A values(6,'f')
go
create trigger tr_a_test on a
after update 
as
begin
 declare @keyId_old int ,@info1_old varchar(20)
 declare @keyId_new int ,@info1_new varchar(20)
  
  ---获取修改前的值
  select @keyId_old=keyId,@info1_old =info1 from deleted  
  ---获取修改后的值
  select @keyId_new=keyId,@info1_new =info1 from inserted    
  ----打印获取的相关值   
   print '-------修改前的值------'   
   print @keyId_old
   print @info1_old   
   print '-------修改后的值------'
   print @keyId_new
   print @info1_new   
end
go

update A set info1='testwwwtwt',keyId=108 where keyId =2 
go
drop trigger  tr_a_test
go
truncate table A
drop table A 
go
 
 
 
mybatis
 
 
 
 create TRIGGER ${triggerName}

        ON ${tableName}

        AFTER INSERT ,UPDATE ,DELETE

        AS
        BEGIN

       declare @id varchar(11)
       declare @url varchar(255)
       declare @object int
       declare @responseText varchar(255)
 --删除
    if(not exists(select 1 from inserted) and exists(select 1 from deleted))

          select @id=${titleId} from deleted
    ELSE
    ---获取修改后的值
      select @id=${titleId} from inserted
      print @id
        set @url = 'http://${urlApi}/${controUrl}?id='+@id;
        print @url


    Exec sp_OACreate 'Msxml2.ServerXMLHTTP.3.0', @Object OUT;
    exec sp_OAMethod @object,'open',null,'get',@url,'false'

    exec sp_OAMethod @object,'send'
    exec sp_OAMethod @object,'responseText',@responseText output

    Exec sp_OADestroy @Object
    EXEC sp_OAGetErrorInfo @Object --异常输出

END;
 
现在只要在数据库执行这个sql into demo (name) values  ('你真的很棒啊'); 就可以访问接口
 
这里有个坑啊     如果你的表名是demo，接收java接口的@RequestMapping 里也是叫demo, 那么无论你在怎么增加  它都不会跑到这个方法
 
嗨！出错了嘛？ 看这
 
SQL Server 阻止了对组件 'Ole Automation Procedures' 的 过程'sys.sp_OACreate' 的访问
 
借鉴博客:
 
http://www.manongjc.com/article/44753.html
 
https://www.jianshu.com/p/244c3cc30123
 
https://www.cnblogs.com/tohen/p/4265263.html
 
https://www.cnblogs.com/lflyq/archive/2016/11/15/6065160.html
 
做个记录...
 
用数据库推送 websocket接收渲染前端页面应该是  万瑞古德！
 
 
 
-----------------补存-------2020年12月9日11:20:40
 
之前写的触发器向指定接口传数据，只是写了一个demo，并没有真正使用，后续使用遇到一些问题，做一些记录
 
问题:
 
使用mybatis创建触发器和存储过程后,在数据库里添加demo表中的数据,由于传的参数是id,在接口里查询当前参数id的值,结果mybatis查询走到mapper层就卡死了,当前百思不得其解,以为是程序写的有问题。经过不断的摸索和实验最后发现当在数据库中添加
 
一条数据时触发器立马请求存储过程中的http接口,然后接口根据id查询最新的数据，为啥会卡死呢？原因就是触发器之前，这个事务并未结束,insert并没有真正的添加到数据库中,所以导致一系列问题.
 
解决:
 
我的解决思路很简单，上代码
 
 new Thread(() -> {
                try {
                    //放到多线程中等待1-2秒,等他的事务完事后在查询
                    Thread.sleep(1500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
              
            }).start();
 
如有问题,请指出
 
 

需求：扫描数据库表数据， 待发送，发送失败且次数不超过3次的的数据，推送到别的系统
 通过对方提供的xml报文
 
拼接报文代码：public static String getXML(Map<String, Object> noSucDataMap) {
 String title = noSucDataMap.get(“noticeName”) == null ? “” : noSucDataMap.get(“noticeName”).toString();
 Object projectName = noSucDataMap.get(“tenderName”) == null ? “” : noSucDataMap.get(“tenderName”).toString();
 Object RegionCode = noSucDataMap.get(“regionCode”) == null ? “” : noSucDataMap.get(“regionCode”).toString();
 Object NoticeContent = noSucDataMap.get(“noticeContent”) == null ? “” : noSucDataMap.get(“noticeContent”).toString();
 Object tenderType = noSucDataMap.get(“tenderType”) == null ? “” : noSucDataMap.get(“tenderType”).toString();
 Object createTime = noSucDataMap.get(“createTime”);
 Object bidOpenTime = noSucDataMap.get(“bid_open_time”);
 DateFormat df = new SimpleDateFormat(“yyyy-MM-dd’T’HH:mm:ss”);
 String createTimeStr = df.format(createTime);
 String bidOpenTimeStr = “”;
 if (bidOpenTime != null) {
 bidOpenTimeStr = df.format(bidOpenTime);
 }else {
 System.out.println(“开标时间不能为空！”);
 }
 
    String soapXML = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" +
            "<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">\n" +
            "  <soap:Body>\n" +
            "    <InsertNoticeInfo xmlns=\"http://tempuri.org/\">\n" +
            "      <userName>test</userName>\n" +
            "      <passWord>111111</passWord>\n" +
            "      <model>\n" +
            "        <NoticeInfoId>0</NoticeInfoId>\n" +
            "        <CategoryId>0</CategoryId>\n" +
            "        <NoticeType>0</NoticeType>\n" +
            "        <Title>" + title + "</Title>\n" +
            "        <Author></Author>\n" +
            "        <Source></Source>\n" +
            "        <UploadFileExplain></UploadFileExplain>\n" +
            "        <UploadFilePath></UploadFilePath>\n" +
            "        <OwnerUnit_ContactPerson></OwnerUnit_ContactPerson>\n" +
            "        <OwnerUnit_Name></OwnerUnit_Name>\n" +
            "        <OwnerUnit_Phone></OwnerUnit_Phone>\n" +
            "        <Qualification></Qualification>\n" +
            "        <Agency_Name></Agency_Name>\n" +
            "        <Agency_ContactPerson></Agency_ContactPerson>\n" +
            "        <Agency_Phone></Agency_Phone>\n" +
            "        <Tender></Tender>\n" +
            "        <TenderType>" + tenderType + "</TenderType>\n" +
            "        <RegionCode>" + RegionCode + "</RegionCode>\n" +
            "        <ProjectName>" + projectName + "</ProjectName>\n" +
            "        <ForecastSuccessfulcandidate></ForecastSuccessfulcandidate>\n" +
            "        <TransactionAmount>0</TransactionAmount>\n" +
            "        <ProjectLeader></ProjectLeader>\n" +
            "        <NoticeContent><![CDATA[" + NoticeContent + "]]></NoticeContent>\n" +
            "        <CreateTime>" + createTimeStr + "</CreateTime>\n" +
            "        <CreateUserId></CreateUserId>\n" +
            "        <TenderDeadline>" + bidOpenTimeStr + "</TenderDeadline>\n" +
            "        <Credential></Credential>\n" +
            "        <Status>0</Status>\n" +
            "        <IsSend>true</IsSend>\n" +
            "        <Scale></Scale>\n" +
            "        <BidPerson></BidPerson>\n" +
            "        <EvaluationBidExpenses>0</EvaluationBidExpenses>\n" +
            "        <State></State>\n" +
            "        <ProjectFilingUN></ProjectFilingUN>\n" +
            "        <ProjectApprovalUN></ProjectApprovalUN>\n" +
            "        <ChapterNumber>0</ChapterNumber>\n" +
            "        <BiddingScope></BiddingScope>\n" +
            "        <BidTime>" + bidOpenTimeStr + "</BidTime>\n" +
            "        <PlanTime></PlanTime>\n" +
            "        <ProjectCondition></ProjectCondition>\n" +
            "        <BidWay></BidWay>\n" +
            "        <BidAddress></BidAddress>\n" +
            "        <PublishMedia></PublishMedia>\n" +
            "        <SectionName></SectionName>\n" +
            "        <OpenAddress></OpenAddress>\n" +
            "        <FirstPerson></FirstPerson>\n" +
            "        <FirstPrice>0</FirstPrice>\n" +
            "        <FirstProjectPerson></FirstProjectPerson>\n" +
            "        <SecondPerson></SecondPerson>\n" +
            "        <SecondPrice>0</SecondPrice>\n" +
            "        <SecondProjectPerson></SecondProjectPerson>\n" +
            "        <TenderPerson></TenderPerson>\n" +
            "        <TenderPrice>0</TenderPrice>\n" +
            "        <TenderProjectPerson></TenderProjectPerson>\n" +
            "        <CreateUsername></CreateUsername>\n" +
            "        <PriceSource></PriceSource>\n" +
            "      </model>\n" +
            "      <categoryId>" + tenderType + "</categoryId>\n" +
            "      <fBytes></fBytes>\n" +
            "      <errorString></errorString>\n" +
            "    </InsertNoticeInfo>\n" +
            "  </soap:Body>\n" +
            "</soap:Envelope>";
    return soapXML;
}
 
//业务逻辑
 public void selLogsNoSuc() {
 List<Map<String, Object>> noSucDataList = winBidCandidateDao.selLogsNoSuc();
 // List sendSucCode = new ArrayList();
 for (int i = 0; i < noSucDataList.size(); i++) {
 Map<String, Object> noSucDataMap = noSucDataList.get(i);
 
        //获取报文
        String soapXML = getXML(noSucDataMap);
        WebserviceResultBean ret = sendDataAhtbaWebService(soapXML);
        int id = Integer.parseInt(String.valueOf(noSucDataMap.get("id")));
        LogsAhszbtbxxw logsAhszbtbxxwNum = winBidCandidateDao.selLogsAhsInfoById(id);
        int sendNum = logsAhszbtbxxwNum.getSendNum() + 1;
        LogsAhszbtbxxw logsAhszbtbxxwObj = new LogsAhszbtbxxw();
        logsAhszbtbxxwObj.setId(id);
        logsAhszbtbxxwObj.setSendNum(sendNum);

        //创建名字表对象
        LogsAhszbtbxxwDetail logsAhszbtbxxwDetail = new LogsAhszbtbxxwDetail();
        Object noticeId = noSucDataMap.get("noticeId");
        if (noticeId != null) {
            logsAhszbtbxxwDetail.setNoticeId(noticeId.toString());
        }
        logsAhszbtbxxwDetail.setNoticeId(noSucDataMap.get("noticeId").toString());
        logsAhszbtbxxwDetail.setSendTime(new Date());
        logsAhszbtbxxwDetail.setXml(soapXML);

        if ("true".equals(ret.getResult())) {
            logsAhszbtbxxwObj.setStates("1");
            logsAhszbtbxxwDetail.setRemarks(ret.getRemark());
            logsAhszbtbxxwDetail.setStates("1");
        } else {
            logsAhszbtbxxwObj.setStates("2");
            logsAhszbtbxxwDetail.setStates("2");
            String remark = ret.getRemark() == null ? "" : ret.getRemark();
            logsAhszbtbxxwDetail.setRemarks(ret.getResult() + remark);
 
// logsAhszbtbxxwDetail.setRemarks();
 }
 winBidCandidateDao.updateStates(logsAhszbtbxxwObj);
 winBidCandidateDao.insertLogsDetail(logsAhszbtbxxwDetail);
 }
 System.out.println(“扫描logs_ahszbtbxxw 待发送，发送失败且次数不超过3次的公告”);
 }
 
//调用接口逻辑
 
public static WebserviceResultBean sendDataAhtbaWebService(String soapXML) {
 // int responseCode=500;
 WebserviceResultBean ret = new WebserviceResultBean();
 try {
 //1：创建服务地址 接口地址
 URL url = new URL(“http://60.173.235.154:9021/ahtbaWebService.asmx”);
 //2：打开到服务地址的一个连接
 try {
 HttpURLConnection connection = (HttpURLConnection) url.openConnection();
 //3.1设置发送方式：POST必须大写
 connection.setRequestMethod(“POST”);
 //3.2设置数据格式：Content-type
 connection.setRequestProperty(“content-type”, “text/xml;charset=utf-8”);
 connection.setDoInput(true);
 connection.setDoOutput(true);
 
            //4：组织SOAP协议数据，发送给服务端
 
// String soapXML = getXML(“1866666666”);
 byte[] b = soapXML.getBytes(); //封装数据，数据以byte方式传输
 connection.setRequestProperty(“Content-Length”, String.valueOf(b.length));
 
            OutputStream os = connection.getOutputStream();
            os.write(b);

            //5：接收服务端的响应
            int responseCode = connection.getResponseCode();
            if (200 == responseCode) {
                InputStream is = connection.getInputStream();
                InputStreamReader isr = new InputStreamReader(is);
                BufferedReader br = new BufferedReader(isr);
                StringBuilder sb = new StringBuilder();
                String temp = null;

                while (null != (temp = br.readLine())) {
                    sb.append(temp);
                }
                System.out.println(sb.toString());
                String sbXML = sb.toString();
                ret = parseSoapMessage(sbXML);
            } else {
                ret.setResult(String.valueOf(responseCode));
            }
 
//
 // InputStream is1 = connection.getErrorStream();
 // InputStreamReader isr1 = new InputStreamReader(is1,“utf-8”);
 // BufferedReader in = new BufferedReader(isr1);
 // String inputLine;
 // BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
 // new FileOutputStream(“result.xml”)));// 将结果存放的位置
 // while ((inputLine = in.readLine()) != null)
 // {
 // System.out.println(inputLine);
 // bw.write(inputLine);
 // bw.newLine();
 // bw.close();
 // }
 // in.close();
 os.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 
    } catch (MalformedURLException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }

    return ret;
}
 
//解析接口返回的报文信息
 
/**
 * 解析soapXML
 *
 * @param soapXML
 * @return
 */
public static WebserviceResultBean parseSoapMessage(String soapXML) {
    WebserviceResultBean resultBean = new WebserviceResultBean();
    try {
        SOAPMessage msg = formatSoapString(soapXML);
        SOAPBody body = msg.getSOAPBody();
        Iterator<SOAPElement> iterator = body.getChildElements();
        parse(iterator, resultBean);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return resultBean;
}
 
/**
 * 把soap字符串格式化为SOAPMessage
 *
 * @param soapString
 * @return
 * @see [类、类#方法、类#成员]
 */
 private static SOAPMessage formatSoapString(String soapString) {
 MessageFactory msgFactory;
 try {
 msgFactory = MessageFactory.newInstance();
 SOAPMessage reqMsg = msgFactory.createMessage(new MimeHeaders(),
 new ByteArrayInputStream(soapString.getBytes(“UTF-8”)));
 reqMsg.saveChanges();
 return reqMsg;
 } catch (Exception e) {
 e.printStackTrace();
 return null;
 }
 }
 
/**
 * 解析soap xml
 *
 * @param iterator
 * @param resultBean
 */
 private static void parse(Iterator iterator, WebserviceResultBean resultBean) {
 while (iterator.hasNext()) {
 SOAPElement element = iterator.next();
 if (“InsertNoticeInfoResponse”.equals(element.getNodeName())) {
 Iterator it = element.getChildElements();
 SOAPElement el = null;
 while (it.hasNext()) {
 el = it.next();
 if (“InsertNoticeInfoResult”.equals(el.getLocalName())) {
 resultBean.setResult(el.getValue());
 System.out.println("#### " + el.getLocalName() + " ==== " + el.getValue());
 } else if (“errorString”.equals(el.getLocalName())) {
 resultBean.setRemark(null != el.getValue() ? el.getValue() : “”);
 System.out.println("#### " + el.getLocalName() + " ==== " + el.getValue());
 }
 }
 } else if (null == element.getValue()
 && element.getChildElements().hasNext()) {
 parse(element.getChildElements(), resultBean);
 }
 }
 }
 
这里我的做的是个定时任务
 public void selLogsNoSuc(){
 System.out.println(“扫描logs_ahszbtbxxw 待发送，发送失败且次数不超过3次的公告”);
 winBidCandidateService.selLogsNoSuc();
 }

【电竞数据】电竞实时指数数据API接口调用和数据推送
 实时指数数据接口和推送
 
说明
 用来获取（无延迟）实时指数和玩法状态推送
 当指数数据发生变化时，破晓字节电竞数据API接口会通过websocket推送电竞实时指数变化数据，推送类型参照【推送类型】
 当websocket中断时，也可以通过【变化信息接口】获取中断时遗漏的指数数据更新信息
 
OkHttpClient client = new OkHttpClient().newBuilder()
  .build();
Request request = new Request.Builder()
  .url("https://openapi.dawnbyte.com/api/markets/details?game_id=3&time_stamp=1606700695&level=2&level_id=552")
  .method("GET", null)
  .addHeader("token", "zCYIP4ADbtgZmmP04wQvMI9AKTJx5fPnHUQZtL7eIEjIBHzB7")
  .build();
Response response = client.newCall(request).execute();