微信红包发送小例子

╰半橙微兮° 2022-07-13 14:21 147阅读 0赞

import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.security.KeyStore;
    import java.util.HashMap;
    import java.util.Map;
    import javax.net.ssl.SSLContext;
    import org.apache.http.HttpEntity;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
    import org.apache.http.conn.ssl.SSLContexts;
    import org.apache.http.entity.StringEntity;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.util.EntityUtils;
    import com.jeft.wx.utls.AdvancedUtil;
    import com.jfinal.weixin.sdk.kit.PaymentKit;
    
    / **
     *发送微信红包的测试例，具体执行需要放在服务器
     * /
    public class MoneyTest {
    
    	public static void main（String [] args）{
    		Map <String，String> map = new HashMap <String，String>（）;
    		map.put（“nonce_str”，“”+ AdvancedUtil.getNoceStrPay（））;
    		map.put（“mch_billno”，“”）; //值等于商户号+ yyyymmdd + 10数字要唯一
    		map.put（“mch_id”，“”）; //商户号
    		map.put（“wxappid”，“”）; //微信公众号appid
    		map.put（“send_name”，“天虹百货”）;
    		map.put（“re_openid”，“”）; //对应公众号
    		map.put（“total_amount”，
    				String.valueOf（（int）（Float.parseFloat（“1”）* 100）））;
    		map.put（“total_num”，“1”）;
    		map.put（“wishing”，“感谢您参加猜灯谜活动，祝您元宵节快乐！”）;
    		map.put（“client_ip”，“”）; //服务器地址这个需要跟微信公众平台红包管理里面那个IP地址一样
    		map.put（“act_name”，“猜灯谜抢红包活动”）;
    		map.put（“remark”，“猜越多得越多，快来抢”）;
    		String sign = PaymentKit.createSign（map，“//商户号KEY微信平台生成”）;
    		System.err.println（sign）;
    		map.put（“sign”，sign）;
    		String xml =“”;
    		try{
    			// PaymentKit是jfinal封装好的微信签名工具
    			xml = ssl（
    					“https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack”，
    					PaymentKit.toXml（map））;
    
    			System.err.println（xml）;
    		} catch（Exception e）{
    			e.printStackTrace（）;
    		}}
    	}}
    
    	public static String ssl（String url，String data）{
    		StringBuffer message = new StringBuffer（）;
    		try{ 
    			String mchId =“”; //商户号
    			KeyStore keyStore = KeyStore.getInstance（“PKCS12”）;
    			//证书防止磁盘位置窗口写法
    			String certFilePath =“C：/certs/apiclient_cert.p12”;
    			// linux下
    			if（“/”。equals（File.separator））{
    				certFilePath =“// usr // local // certs // apiclient_cert.p12”;
    			}}
    			FileInputStream instream = new FileInputStream（new File（
    					certFilePath））;
    			keyStore.load（instream，mchId.toCharArray（））;
    			SSLContext sslcontext = SSLContexts.custom（）
    					.loadKeyMaterial（keyStore，mchId.toCharArray（））。build（）;
    			SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory（
    					sslcontext，
    					new String [] {“TLSv1”}，
    					null，
    					SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER）;
    			CloseableHttpClient httpclient = HttpClients.custom（）
    					.setSSLSocketFactory（sslsf）.build（）;
    			HttpPost httpost = new HttpPost（url）;
    			httpost.addHeader（“Connection”，“keep-alive”）;
    			httpost.addHeader（“Accept”，“* / *”）;
    			httpost.addHeader（“Content-Type”，
    					“application / x-www-form-urlencoded; charset = UTF-8“）;
    			httpost.addHeader（“Host”，“api.mch.weixin.qq.com”）;
    			httpost.addHeader（“X-Requested-With”，“XMLHttpRequest”）;
    			httpost.addHeader（“Cache-Control”，“max-age = 0”）;
    			httpost.addHeader（“User-Agent”，
    					“Mozilla / 4.0（兼容; MSIE 8.0; Windows NT 6.0）“）;
    			httpost.setEntity（new StringEntity（data，“UTF-8”））;
    			System.out.println（“executing request”+ httpost.getRequestLine（））;
    			CloseableHttpResponse response = httpclient.execute（httpost）;
    			try{
    				HttpEntity entity = response.getEntity（）;
    				System.out.println（“----------------------------------------”）;
    				System.out.println（response.getStatusLine（））;
    				if（entity！= null）{
    					System.out.println（“Response content length：”
    							+ entity.getContentLength（））;
    					BufferedReader bufferedReader = new BufferedReader（
    							new InputStreamReader（entity.getContent（），“UTF-8”））;
    					String text;
    					while（（text = bufferedReader.readLine（））！= null）{
    						message.append（text）;
    					}}
    				}}
    				EntityUtils.consume（entity）;
    			} catch（IOException e）{
    				e.printStackTrace（）;
    			} finally {
    				response.close（）;
    			}}
    		} catch（Exception e1）{
    			e1.printStackTrace（）;
    		}}
    		return message.toString（）;
    	}}
    }}

maven：

<dependency>  
<groupId> com.jfinal </ groupId>  
<artifactId> jfinal-weixin </ artifactId>  
<version> 1.7 </ version>  
</ dependency>

<dependency>  
<groupId> commons-logging </ groupId>  
<artifactId> commons-logging </ artifactId>  
<version> 1.1.2 </ version>  
</ dependency>  
<dependency>  
<groupId> org.apache.httpcomponents </ groupId>  
<artifactId> fluent-hc </ artifactId>  
<version> 4.3.4 </ version>  
</ dependency>  
<dependency>  
<groupId> org.apache.httpcomponents </ groupId>  
<artifactId> httpclient </ artifactId>  
<version> 4.3.4 </ version>  
</ dependency>  
<dependency>  
<groupId> org.apache.httpcomponents </ groupId>  
<artifactId> httpclient-cache </ artifactId>  
<version> 4.3.4 </ version>  
</ dependency>  
<dependency>  
<groupId> org.apache.httpcomponents </ groupId>  
<artifactId> httpcore </ artifactId>  
<version> 4.3.2 </ version>  
</ dependency>  
<dependency>  
<groupId> org.apache.httpcomponents </ groupId>  
<artifactId> httpmime </ artifactId>  
<version> 4.3.4 </ version>  
</ dependency>  
<dependency>  
<groupId> xmlpull </ groupId>  
<artifactId> xmlpull </ artifactId>  
<version> 1.1.2.1 </ version>  
</ dependency>

结果：

![Center][]

如有不懂   wb\_90@foxmail.com 咨询  因为上面代码 有可能发表的时候 会被串改成中文或者 乱了

[Center]: /images/20220713/ea2af3b3a8844ced88c86c74b5876e89.png