关于Htdubbox1.3.0的dubbo协议端口的测试问题

wangyuwen 发布于 2018/11/16 18:06
阅读 68
收藏 0

dubbo工程打包到服务器上运行测试发布的接口时报异常,不知为何,求大神解答?

 

 

对应的接口:

package com.htsc.sdgp.internal.monitor.service;

import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicIntegerArray;

import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import com.htsc.sdgp.internal.monitor.pojo.TestPojoInPojo;


@Path("/testServiceOther/")
@Produces({ MediaType.APPLICATION_JSON + "; " + MediaType.CHARSET_PARAMETER + "=UTF-8",
        MediaType.TEXT_XML + "; " + MediaType.CHARSET_PARAMETER + "=UTF-8" })
public interface TestService {

    /**
     * pojo里面套一层pojo
     * 
     * @param pojo
     */
    @POST
    @Path("testPojoInP")
    void testPojoInP(TestPojoInPojo pojo);

    /**
     * 可变长参数,String
     * 
     * @param args
     * @return
     */
    @POST
    @Path("testMoreParam")
    Object testMoreParam(String... args);

    @POST
    @Path("testBigDecimal")
    String testBigDecimal(BigDecimal big);

    @POST
    @Path("testVariableParam")
    Object testVariableParam(List<List<String>>[] args);

    @POST
    @Path("testSleep")
    String testSleep();

    @POST
    @Path("retryInvoke")
    String retryInvoke();

    @POST
    @Path("testThread")
    String testThread();

    @POST
    @Path("testMap")
    String testMap(Map<String, String> map);

    @POST
    @Path("testAtomicIntegerArray")
    String testAtomicIntegerArray(AtomicIntegerArray array);
}
 

 

 

对应的实现类:

package com.htsc.sdgp.internal.monitor.service.impl;

import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
import java.util.ResourceBundle;
import java.util.concurrent.atomic.AtomicIntegerArray;

import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;

import com.htsc.sdgp.internal.monitor.pojo.TestPojoInPojo;
import com.htsc.sdgp.internal.monitor.service.TestService;


@Service
public class TestServiceImpl implements TestService{


    private Logger logger = Logger.getLogger(TestServiceImpl.class);
    
    private ResourceBundle rs=ResourceBundle.getBundle("sdgpstp");
    
    @Override
    public void testPojoInP(TestPojoInPojo pojo) {
        pojo.setName("yu");
        pojo.setTestPojo1(new TestPojoInPojo());
        pojo.getTestPojo1().setName("yu1");
        String s1=pojo.getTestPojo1().getName();
        logger.info(pojo.getName());
        logger.info(s1);
        
    }
    @Override
    public Object  testMoreParam(String... args) {
        for(String s:args) {
            logger.info(s);
        }
        return "stringVariable";
    }
    

    @Override
    public Object testVariableParam(List<List<String>>... args) {
        for(List<List<String>> list:args) {
            logger.info(list.toString());
        }
        return "listVariable";
    }

//    @Override
//    public String test() {
//        logger.info("No Param");
//        return "No Param";
//        
//    }


    @Override
    public String testMap(Map<String,String> map) {
        
      logger.info(map.toString());
      return "testMap";
    }
    
    @Override
    public  String testBigDecimal( BigDecimal big)   {
        big=new BigDecimal(8);
        logger.info(big.intValue());
        return  "bigDecimalValue+"+big.intValue();
    }
    
    @Override
    public String testSleep() {
        Long sleepTime=Long.parseLong(rs.getString("sleepTime"));
        try {
            Thread.sleep(sleepTime);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        return sleepTime+"";
    }

    @Override
    public String retryInvoke() {
        logger.info("retry invoke");
        Long sleepTime=Long.parseLong(rs.getString("sleepTime"));
        try {
            Thread.sleep(sleepTime);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return "retry";
    }
    
    @Override
    public String testThread() {
        logger.info("thread");
        return "thread";
    }


    @Override
    public String testAtomicIntegerArray(AtomicIntegerArray array) {
        logger.info(array.toString());
        return "atomic";
    } 
    
}

 

加载中
返回顶部
顶部