[ 
https://issues.apache.org/jira/browse/IGNITE-10075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113974#comment-17113974
 ] 

Pavel Tupitsyn commented on IGNITE-10075:
-----------------------------------------

[~zzzadruga] yes, please go ahead. I have not started yet.

> .NET: Avoid binary configurations of Ignite Java service params and result 
> when calling it from Ignite.NET
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: IGNITE-10075
>                 URL: https://issues.apache.org/jira/browse/IGNITE-10075
>             Project: Ignite
>          Issue Type: Improvement
>          Components: platforms
>    Affects Versions: 2.6
>            Reporter: Alexey Kukushkin
>            Assignee: Pavel Tupitsyn
>            Priority: Major
>              Labels: .NET, sbcf
>         Attachments: MyTest.cs, ignite-10075-vs-2.8.patch
>
>
> Presently if there is an Ignite Java service taking parameters of complex 
> (composite) types and returning a result of complex type then all the complex 
> types must be explicitly specified in the binary configuration.
> We need to enhance Ignite not to require binary configuration assuming that 
> we use the same type, package/namespace and field/property names on both the 
> .NET and Java sides (or provide a custom name mapper for relaxed naming 
> conventions).
> h2. Reproducer
> h3. ICalculator.java
> {code:java}
> package Sandbox.Net;
> public interface ICalculator {
>     Result Calculate(Parameter p);
> }
> {code}
> h3. Parameter.java
> {code:java}
> package Sandbox.Net;
> public class Parameter {
>     private int id;
>     private double val;
>     public int getId() {
>         return id;
>     }
>     public Parameter setId(int id) {
>         this.id = id;
>         return this;
>     }
>     public double getValue() {
>         return val;
>     }
>     public Parameter setValue(double val) {
>         this.val = val;
>         return this;
>     }
> }
> {code}
> h3. Result .java
> {code:java}
> package Sandbox.Net;
> public class Result {
>     private int id;
>     private double value;
>     public int getId() {
>         return id;
>     }
>     public Result setId(int id) {
>         this.id = id;
>         return this;
>     }
>     public double getValue() {
>         return value;
>     }
>     public Result setValue(double val) {
>         this.value = val;
>         return this;
>     }
> }
> {code}
> h3. IgniteCalculatorService.java
> {code:java}
> package Sandbox.Net;
> import org.apache.ignite.services.Service;
> import org.apache.ignite.services.ServiceContext;
> public class IgniteCalculatorService implements Service, ICalculator {
>     @Override public Result Calculate(Parameter p) {
>         return new Result().setId(p.getId()).setValue(p.getValue() * 
> p.getValue());
>     }
>     @Override public void cancel(ServiceContext ctx) {
>     }
>     @Override public void init(ServiceContext ctx) {
>     }
>     @Override public void execute(ServiceContext ctx) {
>     }
> }
> {code}
> h3. build.gradle
> {code:groovy}
> plugins {
>     id 'java'
> }
> group 'sandbox.net'
> version '1.0-SNAPSHOT'
> sourceCompatibility = 1.8
> repositories {
>     mavenLocal()
>     mavenCentral()
> }
> def igniteVer='2.8.0'
> dependencies {
>     compile group: 'org.apache.ignite', name: 'ignite-core', version: 
> igniteVer
>     testCompile group: 'junit', name: 'junit', version: '4.12'
> }
> {code}
> h3. ignite-config.xml
> {code:xml}
> <?xml version="1.0" encoding="utf-8" ?>
> <beans xmlns="http://www.springframework.org/schema/beans";
>        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
>        xsi:schemaLocation="
>         http://www.springframework.org/schema/beans
>         http://www.springframework.org/schema/beans/spring-beans.xsd";>
>     <bean id="ignite.cfg" 
> class="org.apache.ignite.configuration.IgniteConfiguration">
>         <property name="serviceConfiguration">
>             <list>
>                 <bean class="org.apache.ignite.services.ServiceConfiguration">
>                     <property name="name" value="IgniteCalculatorService"/>
>                     <property name="maxPerNodeCount" value="1"/>
>                     <property name="totalCount" value="0"/>
>                     <property name="service">
>                         <bean class="Sandbox.Net.IgniteCalculatorService"/>
>                     </property>
>                 </bean>
>             </list>
>         </property>
>         <property name="discoverySpi">
>             <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
>                 <property name="ipFinder">
>                     <bean 
> class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
>                         <property name="addresses">
>                             <list>
>                                 <value>127.0.0.1:47500</value>
>                             </list>
>                         </property>
>                     </bean>
>                 </property>
>             </bean>
>         </property>
>     </bean>
> </beans>
> {code}
> h3. ICalculator.cs
> {code:c#}
> namespace Sandbox.Net
> {
>     public interface ICalculator
>     {
>         Result Calculate(Parameter p);
>     }
> }
> {code}
> h3. Parameter.cs
> {code:c#}
> namespace Sandbox.Net
> {
>     public class Parameter
>     {
>         public int Id { get; set; }
>         public double Value { get; set; }
>     }
> }
> {code}
> h3. Result.cs
> {code:c#}
> namespace Sandbox.Net
> {
>     public class Result
>     {
>         public int Id { get; set; }
>         public double Value { get; set; }
>     }
> }
> {code}
> h3. Reproducer.cs
> {code:c#}
> using Apache.Ignite.Core;
> using System;
> namespace Sandbox.Net
> {
>     class Reproducer
>     {
>         static void Main(string[] args)
>         {
>             IgniteConfiguration CommonConfig(string name) => new 
> IgniteConfiguration
>             {
>                 IgniteInstanceName = name,
>                 SpringConfigUrl = "ignite-config.xml",
>                 JvmClasspath = "sandbox.net-1.0-SNAPSHOT.jar"
>             };
>             var igniteServerCfg = CommonConfig("server1");
>             var igniteAppCfg = CommonConfig("app");
>             igniteAppCfg.ClientMode = true;
>             using (var _ = Ignition.Start(igniteServerCfg))
>             using (var ignite = Ignition.Start(igniteAppCfg))
>             {
>                 var calc = 
> ignite.GetServices().GetServiceProxy<ICalculator>("IgniteCalculatorService");
>                 var res = calc.Calculate(new Parameter { Id = 2, Value = 2.0 
> });
>                 Console.WriteLine($">>>>> {res.Value}");
>             }
>         }
>     }
> }
> {code}
> h2. Actual Result Exception
> {code}
> Apache.Ignite.Core.Services.ServiceInvocationException
>  HResult=0x80131500
>  Message=Proxy method invocation failed with an exception. Examine 
> InnerException for details.
>  Source=Apache.Ignite.Core
>  StackTrace:
>  at 
> Apache.Ignite.Core.Impl.Services.ServiceProxySerializer.ReadInvocationResult(IBinaryStream
>  stream, Marshaller marsh, Boolean keepBinary)
>  at 
> Apache.Ignite.Core.Impl.PlatformJniTarget.InObjectStreamOutObjectStream[TR](Int32
>  type, Action`1 writeAction, Func`3 readAction, IPlatformTargetInternal arg)
>  at 
> Apache.Ignite.Core.Impl.Services.Services.<>c__DisplayClass22`1.<GetServiceProxy>b__21(MethodBase
>  method, Object[] args)
>  at Sandbox.Net.Reproducer.Main(String[] args) in 
> C:\Dev\sandbox.net\Sandbox.Net\Reproducer.cs:line 26
> Inner Exception 1:
>  IgniteException: Java exception occurred 
> [class=org.apache.ignite.binary.BinaryInvalidTypeException, 
> message=Requesting mapping from grid failed for [platformId=0, 
> typeId=1340744113]]
> Inner Exception 2:
>  JavaException: class org.apache.ignite.binary.BinaryInvalidTypeException: 
> Requesting mapping from grid failed for [platformId=0, typeId=1340744113]
>  at 
> org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:643)
>  at 
> org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1755)
>  at 
> org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714)
>  at 
> org.apache.ignite.internal.binary.BinaryObjectImpl.deserializeValue(BinaryObjectImpl.java:794)
>  at 
> org.apache.ignite.internal.binary.BinaryObjectImpl.deserialize(BinaryObjectImpl.java:636)
>  at 
> org.apache.ignite.internal.processors.platform.utils.PlatformUtils.unwrapBinary(PlatformUtils.java:912)
>  at 
> org.apache.ignite.internal.processors.platform.utils.PlatformUtils.unwrapBinariesInArray(PlatformUtils.java:980)
>  at 
> org.apache.ignite.internal.processors.platform.services.PlatformServices$ServiceProxyHolder.invoke(PlatformServices.java:579)
>  at 
> org.apache.ignite.internal.processors.platform.services.PlatformServices.processInObjectStreamOutObjectStream(PlatformServices.java:287)
>  at 
> org.apache.ignite.internal.processors.platform.PlatformTargetProxyImpl.inObjectStreamOutObjectStream(PlatformTargetProxyImpl.java:171)
>  Caused by: java.lang.ClassNotFoundException: Requesting mapping from grid 
> failed for [platformId=0, typeId=1340744113]
>  at 
> org.apache.ignite.internal.MarshallerContextImpl.getClassName(MarshallerContextImpl.java:409)
>  at 
> org.apache.ignite.internal.MarshallerContextImpl.getClass(MarshallerContextImpl.java:368)
>  at 
> org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:634)
>  ... 9 more
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to