使用@RequestBody傳遞多個(gè)不同對(duì)象方式

更新時(shí)間：2021年10月22日 11:33:53 作者：一個(gè)喜歡健身的程序員

這篇文章主要介紹了使用@RequestBody傳遞多個(gè)不同對(duì)象方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

@RequestBody傳遞多個(gè)不同對(duì)象

如果使用spring mvc同客戶(hù)端通信，完全使用json數(shù)據(jù)格式，需要增加RequestBody注解，函數(shù)參數(shù)為自定義類(lèi)

@Controller
public class TestController{
  @RequestMapping("\test")
  @ResponseBody
  public RetureResult test(@RequestBody User user){
    return new ReturnResult();
  }  
}

這樣的話(huà)，可以將接收到的json格式的數(shù)據(jù)轉(zhuǎn)換為指定的數(shù)據(jù)對(duì)象user。比如{name:"test"}，name為User類(lèi)的屬性域。通過(guò)ResponseBody注解，可以返回json格式的數(shù)據(jù)。

有時(shí)接收json格式數(shù)據(jù)時(shí)，我們可能需要將其轉(zhuǎn)換為多個(gè)對(duì)象。

以下方式是錯(cuò)誤的。原因是request的content-body是以流的形式進(jìn)行讀取的，讀取完一次后，便無(wú)法再次讀取了。

@Controller
public class TestController{
  @RequestMapping("\test")
  @ResponseBody
  public RetureResult test(@RequestBody User user,@RequestBody Address address){
    return new ReturnResult();
  }  
}

解決方案1

增加一個(gè)包裝類(lèi)，將所需要類(lèi)寫(xiě)入，增加get，set方法

@Controller
public class TestController{
  @RequestMapping("\test")
  @ResponseBody
  public RetureResult test(@RequestBody Param param){
    User user=param.getUser();
    Address address=param.getAddress();
    return new ReturnResult();
  }  
}
class Param{
 
    private User user;
    private Address address;  
 
    public User getUser() {
        return user;
    }
 
    public void setUser(User user) {
        this.user = user;
    }
 
    public Address getAddress() {
        return address;
    }
 
    public void setAddress(Address address) {
        this.address = address;
    }
}

此時(shí)傳輸?shù)膉son數(shù)據(jù)格式變?yōu)閧user:{name:"test"},address:{location:"新華路"}}。

由于只是在TestController中增加一個(gè)包裝類(lèi)，不會(huì)影響其他的類(lèi)以及已經(jīng)定義好的model類(lèi)，因此可以非常方便的達(dá)到接收多個(gè)對(duì)象參數(shù)的目的。

解決方案2

將接收參數(shù)定義為Map<String, Object>，然后使用map轉(zhuǎn)object工具，轉(zhuǎn)換成需要的對(duì)象。

此時(shí)，即使自定義的Param類(lèi)中的屬性即使比json數(shù)據(jù)中的屬性少了，也沒(méi)關(guān)系。

其中JSONUtils為自定義的工具類(lèi)，可使用常見(jiàn)的fastjson等工具包包裝實(shí)現(xiàn)。

@Controller
public class TestController{
  @RequestMapping("\test")
  @ResponseBody
  public Object test(@RequestBody Map<String, Object> models){
　　　User user=JsonXMLUtils.map2object((Map<String, Object>)models.get("user"),User.class); 
　　　Address address=JsonXMLUtils.map2object((Map<String, Object>)models.get("address"),Address.class); 
　　　return models; 
　}
}
import com.alibaba.fastjson.JSON;
 
public class JsonXMLUtils {
    public static String obj2json(Object obj) throws Exception {
        return JSON.toJSONString(obj);
    }
 
    public static <T> T json2obj(String jsonStr, Class<T> clazz) throws Exception {
        return JSON.parseObject(jsonStr, clazz);
    }
 
    public static <T> Map<String, Object> json2map(String jsonStr)     throws Exception {
            return JSON.parseObject(jsonStr, Map.class);
    }
  
    public static <T> T map2obj(Map<?, ?> map, Class<T> clazz) throws Exception {
        return JSON.parseObject(JSON.toJSONString(map), clazz);
    }
}

使用多個(gè)@RequestBody接收參數(shù)

原因

常規(guī)情況下，因?yàn)閞equest的body只能讀取一次，@RequestBody也只能解析一次，這就導(dǎo)致解析第二個(gè)的@RequestBody的時(shí)候stream已經(jīng)關(guān)閉了，無(wú)法再次讀取。

話(huà)不多說(shuō)，上貨：

解決辦法：兩個(gè)類(lèi)，直接copy即可

import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.*; 
public class BodyReaderRequestWrapper extends HttpServletRequestWrapper {
    private final String body;
 
    /**
     *
     * @param request
     */
    public BodyReaderRequestWrapper(HttpServletRequest request) throws IOException{
        super(request);
        StringBuilder sb = new StringBuilder();
        InputStream ins = request.getInputStream();
        BufferedReader isr = null;
        try{
            if(ins != null){
                isr = new BufferedReader(new InputStreamReader(ins));
                char[] charBuffer = new char[128];
                int readCount = 0;
                while((readCount = isr.read(charBuffer)) != -1){
                    sb.append(charBuffer,0,readCount);
                }
            }else{
                sb.append("");
            }
        }catch (IOException e){
            throw e;
        }finally {
            if(isr != null) {
                isr.close();
            }
        }
 
        sb.toString();
        body = sb.toString();
    }
 
    @Override
    public BufferedReader getReader() throws IOException {
        return new BufferedReader(new InputStreamReader(this.getInputStream()));
    }
 
    @Override
    public ServletInputStream getInputStream() throws IOException {
        final ByteArrayInputStream byteArrayIns = new ByteArrayInputStream(body.getBytes());
        ServletInputStream servletIns = new ServletInputStream() {
            @Override
            public boolean isFinished() {
                return false;
            }
 
            @Override
            public boolean isReady() {
                return false;
            }
 
            @Override
            public void setReadListener(ReadListener readListener) {
 
            }
 
            @Override
            public int read() throws IOException {
                return byteArrayIns.read();
            }
        };
        return  servletIns;
    }
}

import org.springframework.stereotype.Component; 
import javax.servlet.*;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
 
@Component
@WebFilter(filterName = "crownFilter", urlPatterns = "/*")
public class BodyReaderRequestFilter implements Filter {
    @Override
    public void init(FilterConfig filterConfig) throws ServletException { 
    }
 
    @Override
    public void doFilter(ServletRequest req, ServletResponse res, FilterChain filterChain) throws IOException, ServletException {
        HttpServletRequest request = (HttpServletRequest)req;
        HttpServletResponse response = (HttpServletResponse)res;
        BodyReaderRequestWrapper requestWrapper  = new BodyReaderRequestWrapper(request);
        if(requestWrapper == null){
            filterChain.doFilter(request,response);
        }else {
            filterChain.doFilter(requestWrapper,response);
        }
    }
 
    @Override
    public void destroy() { 
    }
}

使用：自行測(cè)試。

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: