[C# 2.0]Compression des flux SOAP

Version imprimable

Salut à tous,

Voici mon PB. J'appel un WebService Java depuis mon code C#. Seulement, les données que je passe en entrée des méthodes de ce WebService sont assez importantes. Je souhaiterais donc compresser la demande et réduire ainsi la quantité de donnée qui transite sur le réseau.
J'ai donc mis en place une SoapExtension et j'utilise le namespace System.IO.Compression pour la compression gzip.
Mais mon PB est que ça ne marche pas, ma request ne semble pas compressée.

Voici mon code :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
	public class CompressionExtension : System.Web.Services.Protocols.SoapExtension
	{
		Stream oldStream;
		Stream newStream;
 
		public override Stream ChainStream(Stream stream)
		{
			//return base.ChainStream(stream);
			oldStream = stream;
			newStream = new MemoryStream();
			return newStream;
		}
 
		public override object GetInitializer(Type serviceType)
		{
			return typeof(CompressionExtension);
		}
 
		public override object GetInitializer(System.Web.Services.Protocols.LogicalMethodInfo methodInfo, System.Web.Services.Protocols.SoapExtensionAttribute attribute)
		{
			return attribute;
		}
 
		public override void Initialize(object initializer)
		{
			return;
		}
 
		public override void ProcessMessage(System.Web.Services.Protocols.SoapMessage message)
		{
			switch (message.Stage)
			{
				case System.Web.Services.Protocols.SoapMessageStage.AfterDeserialize:
					break;
				case System.Web.Services.Protocols.SoapMessageStage.AfterSerialize:
					Zip();
					break;
				case System.Web.Services.Protocols.SoapMessageStage.BeforeDeserialize:
					break;
				case System.Web.Services.Protocols.SoapMessageStage.BeforeSerialize:
					message.ContentEncoding = "gzip";
					break;
				default:
					throw new Exception("invalid stage");
					break;
			}
		}
 
		private void Zip()
		{
			newStream.Position = 0;
			newStream = new GZipStream(newStream, CompressionMode.Compress).BaseStream;
			newStream.Position = 0;
			Copy(newStream, oldStream);
		}
 
		void Copy(Stream from, Stream to)
		{
			TextReader reader = new StreamReader(from);
			TextWriter writer = new StreamWriter(to);
			writer.WriteLine(reader.ReadToEnd());
			writer.Flush();
		}
	}

09/11/2007, 10h59
SaumonAgile

Citation:

Envoyé par guitoux1

Mais mon PB est que ça ne marche pas

C'est à dire ?

Citation:

Envoyé par guitoux1

ma request ne semble pas compressée.

Elle l'est ou bien elle ne l'est pas, sur quoi te bases tu pour tester ? analyse des trames ?

Bon c'est bon j'arrive à compresser ma request maintenant. Mais mon PB est que côté Java, il dit que le format n'est pas du GZIP. C'est plutôt bizarre vu que j'utilise un GZipStream ?? je vais essayer avec une autre librairie de compression.
Voilà le code MAJ.

PS : Je me sers de Fiddler pour voir le contenu de la request que j'envoi

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
	public class CompressionExtension : System.Web.Services.Protocols.SoapExtension
	{
		Stream oldStream;
		Stream newStream;
 
		public override Stream ChainStream(Stream stream)
		{
			//return base.ChainStream(stream);
			oldStream = stream;
			newStream = new MemoryStream();
			return newStream;
		}
 
		public override object GetInitializer(Type serviceType)
		{
			return typeof(CompressionExtension);
		}
 
		public override object GetInitializer(System.Web.Services.Protocols.LogicalMethodInfo methodInfo, System.Web.Services.Protocols.SoapExtensionAttribute attribute)
		{
			return attribute;
		}
 
		public override void Initialize(object initializer)
		{
			return;
		}
 
		public override void ProcessMessage(System.Web.Services.Protocols.SoapMessage message)
		{
			switch (message.Stage)
			{
				case System.Web.Services.Protocols.SoapMessageStage.AfterDeserialize:
					break;
				case System.Web.Services.Protocols.SoapMessageStage.AfterSerialize:
					Zip();
					break;
				case System.Web.Services.Protocols.SoapMessageStage.BeforeDeserialize:
					break;
				case System.Web.Services.Protocols.SoapMessageStage.BeforeSerialize:
					message.ContentEncoding = "gzip";
					break;
				default:
					throw new Exception("invalid stage");
					break;
			}
		}
 
		private void Zip()
		{
			newStream.Position = 0;
			MemoryStream ms = new MemoryStream();
			GZipStream gStream = new GZipStream(ms, CompressionMode.Compress);
			byte[] data = new byte[4096];
			int n = 0;
			while ((n = newStream.Read(data, 0, data.Length)) != 0)
			{
				gStream.Write(data, 0, n);
			}
 
			newStream = gStream.BaseStream;
			newStream.Position = 0;
			Copy(newStream, oldStream);
		}
 
		void Copy(Stream from, Stream to)
		{
			TextReader reader = new StreamReader(from);
			TextWriter writer = new StreamWriter(to);
			writer.WriteLine(reader.ReadToEnd());
			writer.Flush();
		}
	}

10/11/2007, 00h54
Mehdi Feki

Il faut fermer ton gzipstream pour que ça fonctionne convenablement

Comment compresser et décompresser un string

Merci.
En fait j'ai trouvé le problème. Il venait de la fonction Copy() qui en utilisant un TextWriter modifier le flux gzip.
J'arrive maintenant correctement à compresser ma request. Mais maintenant j'ai un autre soucis : la décompression automatique de la response ne se fait plus.
Avant, j'utiliser EnableDecompression = true sur mon service, et du coup il ajout Accept-encoding = "gzip" dans le HttpHeader. Le service Java dernière renvoi dans ce cas la response en gzip, et automatiquement DotNet décompresse la response.
Mais depuis la mise en place de cette SoapExtension, la décompression ne fonctionne plus. Pourtant la response est OK (vu avec Fiddler + test sans la SoapExtension). Je comprends pas pourquoi. J'ai alors essayer d'implémenter moi-même la décompression, mais sans succès, j'ai toujours la même erreur, à savoir que le retour n'est pas du XML correct. Voici le code complet de ma SoapExtension :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
 
	public class CompressionExtension : System.Web.Services.Protocols.SoapExtension
	{
		Stream oldStream;
		Stream newStream;
 
		public override Stream ChainStream(Stream stream)
		{
			oldStream = stream;
			newStream = new MemoryStream();
			return newStream;
		}
 
		public override object GetInitializer(Type serviceType)
		{
			return typeof(CompressionExtension);
		}
 
		public override object GetInitializer(System.Web.Services.Protocols.LogicalMethodInfo methodInfo, System.Web.Services.Protocols.SoapExtensionAttribute attribute)
		{
			return attribute;
		}
 
		public override void Initialize(object initializer)
		{
			return;
		}
 
		public override void ProcessMessage(System.Web.Services.Protocols.SoapMessage message)
		{
			switch (message.Stage)
			{
				case System.Web.Services.Protocols.SoapMessageStage.AfterDeserialize:
					break;
				case System.Web.Services.Protocols.SoapMessageStage.AfterSerialize:
					Zip(message.Stream);
					break;
				case System.Web.Services.Protocols.SoapMessageStage.BeforeDeserialize:
					Unzip(message.Stream);
					break;
				case System.Web.Services.Protocols.SoapMessageStage.BeforeSerialize:
					message.ContentEncoding = "gzip";
					break;
				default:
					throw new Exception("invalid stage");
					break;
			}
		}
 
		private void Unzip(Stream message)
		{
			MemoryStream ms = new MemoryStream();
			ms.Position = 0;
			message.Position = 0;
			GZipInputStream zip = new GZipInputStream(message);
			byte[] data = new byte[1024];
			int offset = 0;
 
			while ((offset = zip.Read(data, 0, data.Length)) > 0)
			{
				ms.Write(data, 0, offset);
			}
			ms.Flush();
			ms.Position = 0;
			Copy(ms, newStream);
			zip.Close();
		}
 
		private void Zip(Stream message)
		{
			message.Position = 0;
			MemoryStream ms = new MemoryStream();
			ms.Position = 0;
			message.Position = 0;
			GZipOutputStream zip = new GZipOutputStream(ms);
			byte[] data = new byte[1024];
			int offset = 0;
 
			while ((offset = message.Read(data, 0, data.Length)) > 0)
			{
				zip.Write(data, 0, offset);
			}
			zip.Finish();
			ms.Position = 0;
			Copy(ms, oldStream);
			zip.Close();
		}
 
		void Copy(Stream from, Stream to)
		{
			byte[] data = new byte[1024];
			int offset = 0;
			while ((offset = from.Read(data, 0, data.Length)) != 0)
			{
				to.Write(data, 0, offset);
			}
			to.Flush();
		}
	}