在开始之前需要导入如下的三个文件：
 
在Java文件夹下新建一个lib文件夹，把下面的JCO3文件添加到lib文件后右键lib文件。选择Add to library即可。
 
 
 然后就可以开始写代码。
 
我在整个开始的函数段定义了自己需要的连接字段：
 
private static String ASHOST = "";
    //sap系统编号
    private static String SYSNR = "";
    //sap集团
    private static String CLIENT = "";
    //sap用户名与密码
    private static String USER = "";
    private static String PASSWD = "";
    //语言
    private static String LANG = "";
    //最大连接数
    private static String POOL_CAPACITY = "";
    //最大链接线程
    private static String PEAK_LIMIT = "";
    //SAP ROUTER
    private static String SAPROUTER = "";

    private final static String ABAP_AS_POOLED = "";
 
这是关于SAP初始链接的函数段。
 
/**
     * 初始化SAP连接
     */
    private static void initProperties() {
        Properties connectProperties = new Properties();
        // SAP服务器
        connectProperties.setProperty(DestinationDataProvider.JCO_ASHOST, ASHOST);
        // SAP系统编号
        connectProperties.setProperty(DestinationDataProvider.JCO_SYSNR,SYSNR);
        // SAP集团
        connectProperties.setProperty(DestinationDataProvider.JCO_CLIENT,CLIENT);
        // SAP用户名
        connectProperties.setProperty(DestinationDataProvider.JCO_USER, USER);
        // SAP密码
        connectProperties.setProperty(DestinationDataProvider.JCO_PASSWD, PASSWD);
        // SAP登录语言
        connectProperties.setProperty(DestinationDataProvider.JCO_LANG, LANG);
        // 最大连接数
        connectProperties.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY,POOL_CAPACITY);
        // 最大连接线程
        connectProperties.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT,PEAK_LIMIT);
        // SAP ROUTER
        connectProperties.setProperty(DestinationDataProvider.JCO_SAPROUTER, SAPROUTER);

        createDataFile(ABAP_AS_POOLED, "jcoDestination", connectProperties);
    }
 
createDataFile函数：
 
    /**
     * 创建SAP接口属性文件。
     * @param name  ABAP管道名称
     * @param suffix    属性文件后缀
     * @param properties    属性文件内容
     */
    private static void createDataFile(String name, String suffix, Properties properties){
        File cfg = new File(name+"."+suffix);
        if(cfg.exists()){
            cfg.deleteOnExit();
        }
        try{
            FileOutputStream fos = new FileOutputStream(cfg, false);
            properties.store(fos, "for tests only !");
            fos.close();
        }catch (Exception e){
            System.out.println("Create Data file fault, error msg: " + e.toString());
            throw new RuntimeException("Unable to create the destination file " + cfg.getName(), e);
        }
    }
 
SAP链接：
 
/**
     * 获取SAP连接
     * @return  SAP连接对象
     */
    public static JCoDestination connect(){
        System.out.println("开始尝试链接！");
        //JCoDestination代表后台SAP系统，程序员不用关心与SAP的连接，jco3.0运行时环境负责管理连接和释放连接。
        JCoDestination destination = null;
        initProperties();
        try {
            destination = JCoDestinationManager.getDestination(ABAP_AS_POOLED);
            //调用ping()方法测试SAP系统的连接
            destination.ping();
            System.out.println("成功建立和sap的连接！");
        } catch (JCoException e) {
            System.out.println("链接失败,错误日志: " + e.toString());
        }
        return destination;
    }
 
这次的内容借鉴了如下链接的文章：
 
(一)通过JAVA连接SAP调用接口 (sapjco3.jar在Windows和MacOS上的配置)

 
其实直接在java中调SAP的RFC就可以把数据传到SAP里 但是通过java程序监听SAP, 然后SAP在需要的时候去访问java的程序，要更加安全。因为java访问SAP的话随时都可以，只需要运行java程序。 而从SAP访问java，只有SAP需要的时候，java才能访问SAP数据或者传送数据到SAP。
 
在程序之前要先在SM59里配置。在TCP/IP类型中新建一个 -->取一个destination名字，radiobutton选Registered Server Program. 随便取一个 Promgram ID. 在java里就用这个program id. Geteway host 填Sap服务器地址，Gateway service 填 sapgwnn(nn是System number,如00,01等，在SAP登录界面里选择登录的系统，然后选择“更改项目”，可以看到系统编号(system number)和服务器地址)。
 
SAP代码： z_sap_java这个函数模块只有一个输出参数 return_str. 在java的代码里面给它赋值，传到SAP。
 
REPORT  z_temp_demo.
 
DATA str(100).
 
CALL FUNCTION 'Z_SAP_JAVA' DESTINATION 'Z_TEST_DESTINATION'
 
IMPORTING
 
RETURN_STR       = str
 
.
 
message I000(O0) with str.
 
*********************************************************************************
 
JAVA代码： 类SAPLogon. 只是用来登录SAP，其实是为了取得SAP里的 JCO.Repository 对象。
 
类SAPServer. 用来监听来自SAP的消息。该类必须继承 JCO.Server，因为JCO.SERVER的监听是单独开的一个线程，而监听到有信号来的时候，JCO.SERVER会自动执行其中的protected的方法handleRequest，所以也必须重写该方法。
 
package javaapplication3;
 
import com.sap.mw.jco.*;
 
import com.sap.mw.jco.JCO.Function;
 
class SAPServer extends JCO.Server
 
{
 
public SAPServer(JCO.Repository repo)
 
{
 
super ("10.60.203.100", "sapgw01", "MYABC", repo);
 
}
 
protected void handleRequest(Function arg0) throws Exception {
 
JCO.ParameterList output = arg0.getExportParameterList();
 
output.setValue("Singel Lee", "RETURN_STR");
 
this.stop();
 
}
 
}
 
class SAPLogon
 
{
 
public JCO.Client mConnection;
 
public JCO.Repository mRepository;
 
public SAPLogon(String client, String userid, String password, String language,
 
String ip, String system_number)
 
{
 
try {
 
mConnection = JCO.createClient(client,
 
userid,
 
password,
 
language,
 
ip,
 
system_number);
 
mConnection.connect();
 
mRepository = new JCO.Repository("Lee", mConnection);
 
System.out.println("SAP连接成功");
 
mRepository = new JCO.Repository("my_repository", mConnection);
 
mConnection.disconnect();
 
} catch (Exception ex) {
 
ex.printStackTrace();
 
System.exit(1);
 
}
 
}
 
}
 
public class Main {
 
public static void main(String[] args) {
 
SAPLogon mySAP = new SAPLogon("800", "DEV0008", "*****", "E", "10.60.203.100", "01");
 
SAPServer myServer = new SAPServer(mySAP.mRepository);
 
myServer.start();
 
}
 
}

记录java连接sap接口的过程.
 
https://blog.csdn.net/zhulichen/article/details/52766019
 
这个在本地连接,写的很详细,可以先看这个.jar和dll也有下载地址
 
跟上面的不同点,我的pom引用了
 
<dependency>
             <groupId>org.hibersap</groupId>
             <artifactId>com.sap.conn.jco.sapjco3</artifactId>
             <version>3.0.0</version>
 </dependency>
 
在maven中找到这个文件的地址 F:\maven\apache-maven-3.6.0\mvn\mvnrepository\org\hibersap\com.sap.conn.jco.sapjco3\3.0.0
 
,然后把 sapjco3.jar复制进去,把com.sap.conn.jco.sapjco3-3.0.0.jar删除,把sapjco3.jar名字修改为com.sap.conn.jco.sapjco3-3.0.0.jar.就能在项目中引用.
 
把sapjco3.dll文件复制到 C:\Program Files\jdk\jdk1.8.0_20\bin 中.也就是你自己的java环境地址的bin文件中.
 
所以在windows环境中只需要在项目中引用org.hibersap,替换里面的jar包,改jar名字.
 
然后把sapjco3.dll文件复制一下就行了.具体代码看上面的链接.
 
 
 
linux环境下
 
将sapjco3.jar 文件复制至  $JAVA_HOME/lib/sapjco3.jar 
将 libsapjco3.so 文件复制至 $JAVA_HOME/jre/lib/amd64/server/libsapjco3.so
设置环境变量
vim /etc/profile 修改文件
export JAVA_HOME=/usr/local/java/jdk1.8.0_181
export JAVA_BIN=$JAVA_HOME/bin
export PATH=$PATH:$JAVA_BIN
export CLASSPATH=$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/sapjco3.jar
export LD_LIBRARY_PATH=$JAVA_HOME/jre/lib/amd64/server
红色的就是要添加的
刷新配置
source /etc/profile
 
测试是否安装成功：
 
执行命令：java -jar (java地址)/lib/sapjco3.jar
 
应该就是这样
 
 
需要的文件
 
链接: https://pan.baidu.com/s/10IcSVEVnmlQo7F3UOog3kQ
 
提取码: d74e 复制这段内容后打开百度网盘手机App，操作更方便哦
 
至于连接的错误码,大家百度百度就行了.操作差不多就是这样.
 
 
 
 

SAP目前是世界上最大的也是使用最多的ERP系统，很多大型系统都将自己的业务数据放到了SAP系统来进行管理，那么当别的系统需要这些数据时，就需要从SAP中获取这些数据。SAP中有各种不同类型的接口，RFC，PI等等。下面记录的是java如何调用RFC的接口。网上可以找到很多类似的文章，代码也是以前的老手写的，也比较易懂，这里再记下来主要是为了以后找起来方便。
 
java调用RFC接口需要用到sapjco3.jar，windows下还需要将文件sapjco3.dll文件放到system32的目录下，linux下同样需要把sapjco3.so放入项目的执行目录下。
 
需要的sapjco3.dll、sapjco3.so、sapjco3.jar 我放百度云链接：https://pan.baidu.com/s/1upV7J-JdkiKaH1SczFK6nA        提取码：t33y
 
其实只需要sapjco3.dll（windows）、sapjco3.so（linux）
 
有两种方式：
 
1.sapjco3.jar 放在项目路径下 打包注意一下 具体不详细介绍了。
 
2.Maven的方式引入：
 
<properties>
		<sapjco3.version>3.0.11</sapjco3.version>
</properties>

<dependency>
	    <groupId>com.github.easonjim</groupId>
		<artifactId>com.sap.conn.jco.sapjco3</artifactId>
		<version>${sapjco3.version}</version>
</dependency>
 
代码如下：
 
 
RfcManager.java:
 
package com.thescm.console.jco;

import com.sap.conn.jco.JCoDestination;
import com.sap.conn.jco.JCoDestinationManager;
import com.sap.conn.jco.JCoException;
import com.sap.conn.jco.JCoFunction;
import com.sap.conn.jco.ext.DestinationDataProvider;
import com.sap.conn.jco.ext.Environment;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Properties;

/**
 * RFC 配置中心
 *
 * @author SJ
 * @date 2021-1-4 16:32:01
 */
public final class RfcManager {
    private final static Logger logger = LoggerFactory.getLogger(RfcManager.class);
    private static final String ABAP_AS_POOLED = "ABAP_AS_POOL";
    private static JcoProvider provider;
    private static JCoDestination destination;

    static {
        Properties properties = loadProperties();
        // catch IllegalStateException if an instance is already registered
        try {
            provider = new JcoProvider();
            Environment.registerDestinationDataProvider(provider);
            provider.changePropertiesForABAP_AS(ABAP_AS_POOLED, properties);
        } catch (Exception e) {
            logger.error("RfcManager registerDestinationDataProvider error:"+e.getMessage(), e);
        }
    }

    public static Properties loadProperties() {
        Properties connectProperties = new Properties();
        // SAP服务器
        connectProperties.setProperty(DestinationDataProvider.JCO_ASHOST, "192.168.xx.xx");
        // SAP端口
        connectProperties.setProperty(DestinationDataProvider.JCO_MSSERV, "");
        // SAP系统编号
        connectProperties.setProperty(DestinationDataProvider.JCO_SYSNR, "xx");
        // SAP集团
        connectProperties.setProperty(DestinationDataProvider.JCO_CLIENT, "xxx");
        // SAP用户名
        connectProperties.setProperty(DestinationDataProvider.JCO_USER, "xxxxx");
        // SAP密码
        connectProperties.setProperty(DestinationDataProvider.JCO_PASSWD, "xxxxx");
        // SAP登录语言
        connectProperties.setProperty(DestinationDataProvider.JCO_LANG, "zh");
        // 最大连接数
        connectProperties.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY, "xx");
        // 最大连接线程
        connectProperties.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT, "xx");
        // 连接路由
        connectProperties.setProperty(DestinationDataProvider.JCO_SAPROUTER, "/x/xxxxx");

        return connectProperties;
    }

    public static JCoDestination getDestination() throws JCoException {
        if (destination == null) {
            destination = JCoDestinationManager.getDestination(ABAP_AS_POOLED);
        }
        return destination;
    }

    public static void execute(JCoFunction function) {
        logger.info("SAP Function Name : " + function.getName());
        try {
            function.execute(getDestination());
        } catch (JCoException e) {
            logger.error("RfcManager execute error:", e);
        }
    }

    public static JCoFunction getFunction(String functionName) {
        JCoFunction function = null;
        try {
            function = getDestination().getRepository().getFunctionTemplate(functionName).getFunction();
        } catch (JCoException e) {
            logger.error("RfcManager getFunction JCoException error:", e);
        } catch (NullPointerException e) {
            logger.error("RfcManager getFunction NullPointerException error:", e);
        }
        return function;
    }
}
 
RfcSessionReference.java
 
package com.thescm.console.jco;

import com.sap.conn.jco.ext.JCoSessionReference;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * RFC SESSION 管理中心
 *
 * @author SJ
 * @date 2021-1-4 16:32:21
 */
public class RfcSessionReference implements JCoSessionReference {
    static AtomicInteger atomicInt = new AtomicInteger(0);
    private String id = "session-" + String.valueOf(atomicInt.addAndGet(1));

    @Override
    public void contextFinished() {
    }

    @Override
    public void contextStarted() {
    }

    @Override
    public String getID() {
        return id;
    }

}
 
JcoProvider.java
 
package com.thescm.console.jco;

import com.sap.conn.jco.ext.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.HashMap;
import java.util.Properties;

/**
 * JCO 提供方
 *
 * @author SJ
 * @date 2021-1-4 16:33:02
 */
public class JcoProvider implements DestinationDataProvider, SessionReferenceProvider {

    private final static Logger logger = LoggerFactory.getLogger(JcoProvider.class);
    private HashMap<String, Properties> secureDBStorage = new HashMap<>();
    private DestinationDataEventListener eL;

    @Override
    public Properties getDestinationProperties(String destinationName) {
        try {
            //read the destination from DB
            Properties p = secureDBStorage.get(destinationName);
            if (p != null) {
                //check if all is correct, for example
                if (p.isEmpty()) {
                    logger.info("destination configuration is incorrect!");
                }
                return p;
            }
            logger.info("properties is null ...");
            return null;
        } catch (RuntimeException re) {
            logger.error("internal error!");
            return null;
        }
    }

    @Override
    public void setDestinationDataEventListener(
            DestinationDataEventListener eventListener) {
        this.eL = eventListener;
        logger.info("eventListener assigned ! ");
    }

    @Override
    public boolean supportsEvents() {
        return true;
    }

    /**
     * implementation that saves the properties in a very secure way
     */
    public void changePropertiesForABAP_AS(String destName, Properties properties) {
        synchronized (secureDBStorage) {
            if (properties == null) {
                if (secureDBStorage.remove(destName) != null) {
                    eL.deleted(destName);
                }
            } else {
                secureDBStorage.put(destName, properties);
                // create or updated
                eL.updated(destName);
            }
        }
    }

    @Override
    public JCoSessionReference getCurrentSessionReference(String scopeType) {

        RfcSessionReference sesRef = JcoMutiThread.localSessionReference.get();
        if (sesRef != null) {
            return sesRef;
        }
        throw new RuntimeException("Unknown thread:" + Thread.currentThread().getId());
    }

    @Override
    public boolean isSessionAlive(String sessionId) {
        return false;
    }

    @Override
    public void jcoServerSessionContinued(String sessionID)
            throws SessionException {
    }

    @Override
    public void jcoServerSessionFinished(String sessionID) {

    }

    @Override
    public void jcoServerSessionPassivated(String sessionID)
            throws SessionException {
    }

    @Override
    public JCoSessionReference jcoServerSessionStarted() throws SessionException {
        return null;
    }
}
 
JcoMutiThread.java
 
package com.thescm.console.jco;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Hashtable;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

/**
 * JCO线程操作
 *
 * @author SJ
 * @date 2021-1-4 15:34:35
 */
public class JcoMutiThread extends Thread {

    private final static Logger logger = LoggerFactory.getLogger(JcoMutiThread.class);
    public static Hashtable<IMultiStepJob, RfcSessionReference> sessions = new Hashtable<>();
    public static ThreadLocal<RfcSessionReference> localSessionReference = new ThreadLocal<>();
    private BlockingQueue<IMultiStepJob> queue;
    private CountDownLatch doneSignal;
    private boolean isSapBusy = false;


    public JcoMutiThread(CountDownLatch doneSignal, BlockingQueue<IMultiStepJob> queue) {
        this.doneSignal = doneSignal;
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            for (; ; ) {
                IMultiStepJob job = queue.poll(10, TimeUnit.SECONDS);

                // stop if nothing to do
                if (job == null) {
                    break;
                }
                if (isSapBusy) {
                    Thread.sleep(5000);
                }
                RfcSessionReference sesRef = sessions.get(job);
                if (sesRef == null) {
                    sesRef = new RfcSessionReference();
                    sessions.put(job, sesRef);
                }
                localSessionReference.set(sesRef);
                try {
                    isSapBusy = job.runNextStep();
                } catch (Throwable th) {
                    logger.error("JcoMutiThread runNextStep", th);
                }

                if (isSapBusy) {
                    queue.add(job);
                } else {
                    sessions.remove(job);
                    job.cleanUp();
                }
                localSessionReference.set(null);
            }
        } catch (InterruptedException e) {
            logger.error("JcoMutiThread run", e);
        } finally {
            doneSignal.countDown();
        }
    }
}
 
IMultiStepJob.java
 
package com.thescm.console.jco;

/**
 * 多步骤任务
 *
 * @author SJ
 * @date 2021-1-4 10:10:16
 */
public interface IMultiStepJob {
    boolean runNextStep();

    String getName();

    void cleanUp();
}