C# 示例

using System;
using System.Net;
using System.Windows.Forms;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.IO;
namespace HttpRequestTest
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        private void button1_Click(object sender, EventArgs e)
        {
            CookieContainer cookieContainer = new CookieContainer();
            String serviceUrl = "http://localhost:8060/smartbi";
            Object ret = RemoteInvoker.invokeMethod(cookieContainer, serviceUrl, "UserService", "login", new String[] { "admin", "manager" });
            if (ret.ToString().Equals("True"))
            {
                MessageBox.Show("登录成功");
            }
            else
            {
                MessageBox.Show("登录失败");
                return;
            }
            // 业务查询ID(对应示例库中的"根目录\功能演示\查询定义\原生SQL查询\带参数的原生SQL")
            String bizViewId = "I2c94907127855da201278df551b62602";
            // 参数ID
            String paramId = "OutputParameter.I2c94907127855da201278df551b62602.产品名称参数_列表对话框";
            // 参数真实值
            String paramValue = "牛奶,花生,饼干,猪肉,汽水";
            //
            JObject pobj = new JObject();
            pobj["id"] = paramId;
            pobj["value"] = paramValue;
            JArray arr = new JArray();
            arr.Add(pobj);
            //
            String paramsJsonArrStr = JsonConvert.SerializeObject(arr);
            // 每页行数
            int rowsPerPage = 2;
            // 是否获取总行数
            Boolean getTotalRows = true;
            JObject obj = (JObject)RemoteInvoker.invokeMethod(cookieContainer, serviceUrl, "BusinessViewService",
                "openLoadDataView", new Object[] { bizViewId, paramsJsonArrStr, rowsPerPage, getTotalRows });
            String loadDataClientId = (String)obj["clientId"];
            int totalRows = (int)obj["totalRowCount"];
            JArray fieldNames = (JArray)obj["fieldNames"];
            // JArray fieldTypes = (JArray)ret["fieldTypes"];           
            String fNames = "";
            for (int i = 0; i < fieldNames.Count; i++)
            {
                fNames += fieldNames[i].ToString() + "\t";
            }
            textBox1.AppendText(fNames + "\n");
            int pages = totalRows / rowsPerPage + (totalRows % rowsPerPage == 0 ? 0 : 1);
            for (int pageNum = 0; pageNum < pages; pageNum++)
            {
                JArray pageData = (JArray)RemoteInvoker.invokeMethod(cookieContainer, serviceUrl, "BusinessViewService",
                    "loadViewData", new Object[] { loadDataClientId, pageNum });
                for (int j = 0; j < pageData.Count; j++)
                {
                    String line = "";
                    JArray rowData = (JArray)pageData[j];
                    for (int k = 0; k < rowData.Count; k++)
                    {
                        line += (String)rowData[k] + "\t";
                    }
                    textBox1.AppendText(line + "\n");
                }
            }
            RemoteInvoker.invokeMethod(cookieContainer, serviceUrl, "BusinessViewService", "closeLoadDataView", new Object[] { loadDataClientId });
        }
        private void button2_Click(object sender, EventArgs e)
        {
            CookieContainer cookieContainer = new CookieContainer();
            String serviceUrl = "http://localhost:8060/smartbi";
            Object ret = RemoteInvoker.invokeMethod(cookieContainer, serviceUrl, "UserService", "login", new String[] { "admin", "manager" });
            if (ret.ToString().Equals("True"))
            {
                MessageBox.Show("登录成功");
            }
            else
            {
                MessageBox.Show("登录失败");
                return;
            }
            String resid = "I2c94908d162343520116234cb928003d";
            JObject reportRet = (JObject)RemoteInvoker.invokeMethod(cookieContainer, serviceUrl, "ClientReportService", "openQuery", new String[] { resid });
            JObject reportBean = (JObject)reportRet["reportBean"];
            String clientId = (String)reportRet["clientId"];
            String downloadURL = serviceUrl + "/vision/ExportServlet?delimiter=,&type=EXCEL2007&clientId=" + clientId;
            FileStream stream = new FileStream(@"E:\11.xlsx", FileMode.OpenOrCreate, FileAccess.Write);
            RemoteInvoker.InvokeDownload(cookieContainer, downloadURL, "post", stream);
            stream.Close();
            RemoteInvoker.invokeMethod(cookieContainer, serviceUrl, "ClientReportService", "removeFromSession", new String[] { clientId });
        }
    }
}

using System;
using System.IO;
using System.Net;
using System.Text;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.Net.Cache;
namespace HttpRequestTest
{
    public class RemoteInvoker
    {
        public static String encode = "UTF-8";
        public static void setEncode(String settingEncode)
        {
            encode = settingEncode;
        }
        public static Object invokeMethod(CookieContainer cookieContainer,
                String serviceUrl, String serviceName,
                String methodName, Object[] methodParams)
        {
            String paramInfo = JsonConvert.SerializeObject(methodParams);
            return RemoteInvoker.invokeBIOfficeRMIService(cookieContainer, serviceUrl, serviceName, methodName, paramInfo);
        }
        public static Object invokeBIOfficeRMIService(CookieContainer cookieContainer,
            String serviceUrl, String serviceName,
            String methodName, String paramInfo)
        {
            WebResponse response = null;
            HttpWebRequest req = null;
            try
            {
                byte[] bytes = Encoding.GetEncoding(encode).GetBytes(paramInfo);
                String temp = Encoding.Default.GetString(bytes);
                String requestURL = serviceUrl + "/vision/RMIServlet";
                String postData = "className=" + serviceName + "&methodName=" + methodName
                    + "&params=" + paramInfo;
                byte[] data = Encoding.GetEncoding(encode).GetBytes(postData);
                req = (HttpWebRequest)HttpWebRequest.Create(requestURL);
                req.CookieContainer = cookieContainer;
                req.Method = "POST";
                req.ContentType = "application/x-www-form-urlencoded";
                req.ContentLength = data.Length;
                Stream reqStream = req.GetRequestStream();
                reqStream.Write(data, 0, data.Length);
                reqStream.Close();
                response = req.GetResponse();
                Stream stream = response.GetResponseStream();
                StreamReader sr = new StreamReader(stream, Encoding.GetEncoding(encode));
                String result = sr.ReadToEnd();
                JObject jsonObj = JObject.Parse(result);
                if ((int)jsonObj["retCode"] == 0)
                {
                    return jsonObj["result"];
                }
            }
            catch
            {
            }
            finally
            {
                response.Close();
                req.Abort();
            }
            return null;
        }
        public static void InvokeDownload(CookieContainer cookieContainer,
            String requestUrl, String method, byte[] data, Stream stream)
        {
            WebResponse wr = null;
            try
            {
                var req = (HttpWebRequest)HttpWebRequest.Create(requestUrl);
                /* 禁用缓存 */
                req.CachePolicy = new HttpRequestCachePolicy(HttpRequestCacheLevel.NoCacheNoStore);
                req.Method = method;
                req.CookieContainer = cookieContainer;
                if (data != null)
                {
                    req.ContentType = "application/x-www-form-urlencoded";
                    Stream s = req.GetRequestStream();
                    s.Write(data, 0, data.Length);
                    s.Close();
                }
                wr = req.GetResponse();
                CopyStream(wr.GetResponseStream(), stream);
                req.Abort();
            }
            finally
            {
                try
                {
                    wr.Close();
                }
                catch
                {
                }
            }
        }

        public static void CopyStream(Stream input, Stream output)
        {
            byte[] buffer = new byte[32768];
            while (true)
            {
                int read = input.Read(buffer, 0, buffer.Length);
                if (read <= 0)
                    return;
                output.Write(buffer, 0, read);
            }
        }
    }
}