diff --git a/ClientTest/ClientTest.csproj b/ClientTest/ClientTest.csproj
index 0cc8320..997b4d3 100644
--- a/ClientTest/ClientTest.csproj
+++ b/ClientTest/ClientTest.csproj
@@ -21,7 +21,7 @@
<ItemGroup>
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.11.1" />
- <PackageReference Include="NewLife.Redis" Version="5.7.2024.801" />
+ <PackageReference Include="NewLife.Redis" Version="6.0.2024.829-beta1442" />
<PackageReference Include="NewLife.UnitTest" Version="1.0.2024.102-beta0146" />
<PackageReference Include="xunit" Version="2.9.0" />
<PackageReference Include="xunit.runner.visualstudio" Version="2.8.2">
diff --git a/Samples/TestA/TestA.csproj b/Samples/TestA/TestA.csproj
index bff0f20..f1f6124 100644
--- a/Samples/TestA/TestA.csproj
+++ b/Samples/TestA/TestA.csproj
@@ -18,7 +18,7 @@
</PropertyGroup>
<ItemGroup>
- <PackageReference Include="NewLife.Core" Version="10.10.2024.902" />
+ <PackageReference Include="NewLife.Core" Version="11.0.2024.916-beta1549" />
</ItemGroup>
</Project>
diff --git a/Samples/TestB/TestB.csproj b/Samples/TestB/TestB.csproj
index 338911c..89100ea 100644
--- a/Samples/TestB/TestB.csproj
+++ b/Samples/TestB/TestB.csproj
@@ -18,7 +18,7 @@
</PropertyGroup>
<ItemGroup>
- <PackageReference Include="NewLife.Core" Version="10.10.2024.902" />
+ <PackageReference Include="NewLife.Core" Version="11.0.2024.916-beta1549" />
</ItemGroup>
</Project>
diff --git a/StarAgent/StarAgent.csproj b/StarAgent/StarAgent.csproj
index 8346e58..8f890dd 100644
--- a/StarAgent/StarAgent.csproj
+++ b/StarAgent/StarAgent.csproj
@@ -2,12 +2,12 @@
<PropertyGroup>
<OutputType>Exe</OutputType>
- <TargetFrameworks>netcoreapp3.1;net5.0;net6.0;net40;net45;net461;net7.0;net8.0</TargetFrameworks>
+ <TargetFrameworks>netcoreapp3.1;net5.0;net6.0;net45;net461;net7.0;net8.0</TargetFrameworks>
<AssemblyTitle>星尘代理</AssemblyTitle>
<Description>星尘,分布式资源调度,部署于每一个节点,连接服务端,支持节点监控、远程发布。</Description>
<Company>新生命开发团队</Company>
<Copyright>©2002-2024 NewLife</Copyright>
- <VersionPrefix>3.0</VersionPrefix>
+ <VersionPrefix>3.1</VersionPrefix>
<VersionSuffix>$([System.DateTime]::Now.ToString(`yyyy.MMdd`))</VersionSuffix>
<Version>$(VersionPrefix).$(VersionSuffix)</Version>
<FileVersion>$(Version)</FileVersion>
diff --git a/Stardust.Extensions/Stardust.Extensions.csproj b/Stardust.Extensions/Stardust.Extensions.csproj
index 9e673d0..939af0e 100644
--- a/Stardust.Extensions/Stardust.Extensions.csproj
+++ b/Stardust.Extensions/Stardust.Extensions.csproj
@@ -7,7 +7,7 @@
<Description>星尘,分布式服务框架扩展。节点管理,监控中心,配置中心,发布中心,注册中心</Description>
<Company>新生命开发团队</Company>
<Copyright>©2002-2024 NewLife</Copyright>
- <VersionPrefix>3.0</VersionPrefix>
+ <VersionPrefix>3.1</VersionPrefix>
<VersionSuffix>$([System.DateTime]::Now.ToString(`yyyy.MMdd`))</VersionSuffix>
<Version>$(VersionPrefix).$(VersionSuffix)</Version>
<FileVersion>$(Version)</FileVersion>
diff --git a/Stardust.Server/Stardust.Server.csproj b/Stardust.Server/Stardust.Server.csproj
index cdc2683..16902fa 100644
--- a/Stardust.Server/Stardust.Server.csproj
+++ b/Stardust.Server/Stardust.Server.csproj
@@ -45,7 +45,7 @@
<ItemGroup>
<PackageReference Include="NewLife.IP" Version="2.2.2024.902" />
- <PackageReference Include="NewLife.Redis" Version="5.7.2024.801" />
+ <PackageReference Include="NewLife.Redis" Version="6.0.2024.829-beta1442" />
<PackageReference Include="NewLife.Remoting.Extensions" Version="3.0.2024.902" />
</ItemGroup>
diff --git a/Stardust.Web/Stardust.Web.csproj b/Stardust.Web/Stardust.Web.csproj
index 52942fc..38f073a 100644
--- a/Stardust.Web/Stardust.Web.csproj
+++ b/Stardust.Web/Stardust.Web.csproj
@@ -52,7 +52,7 @@
<ItemGroup>
<PackageReference Include="NewLife.Cube.Core" Version="6.1.2024.902" />
<PackageReference Include="NewLife.IP" Version="2.2.2024.902" />
- <PackageReference Include="NewLife.Redis" Version="5.7.2024.801" />
+ <PackageReference Include="NewLife.Redis" Version="6.0.2024.829-beta1442" />
<PackageReference Include="NewLife.Remoting.Extensions" Version="3.0.2024.902" />
</ItemGroup>
diff --git a/Stardust/LocalStarClient.cs b/Stardust/LocalStarClient.cs
index d887739..1ea6af9 100644
--- a/Stardust/LocalStarClient.cs
+++ b/Stardust/LocalStarClient.cs
@@ -5,6 +5,7 @@ using System.Net;
using System.Net.NetworkInformation;
using System.Net.Sockets;
using NewLife;
+using NewLife.Data;
using NewLife.Http;
using NewLife.Log;
using NewLife.Messaging;
@@ -470,8 +471,10 @@ public class LocalStarClient
//};
//var buf = msg.ToPacket().ToArray();
- var buf = encoder.CreateRequest("Info", null).ToPacket()?.ToArray();
- if (buf == null) yield break;
+ var pk = encoder.CreateRequest("Info", null).ToPacket();
+ if (pk == null) yield break;
+
+ var buf = pk.ToArray();
// 在局域网中广播消息
var udp = new UdpClient();
@@ -483,7 +486,7 @@ public class LocalStarClient
var rs = new DefaultMessage();
IPEndPoint? ep = null;
buf = udp.Receive(ref ep);
- if (buf != null && rs.Read(buf))
+ if (buf != null && rs.Read((ArrayPacket)buf))
{
var msg = encoder.Decode(rs);
if (msg != null && msg.Data != null)
diff --git a/Stardust/Stardust.csproj b/Stardust/Stardust.csproj
index 8e8b3ae..d3609a3 100644
--- a/Stardust/Stardust.csproj
+++ b/Stardust/Stardust.csproj
@@ -1,13 +1,13 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
- <TargetFrameworks>net40;net45;net461;netstandard2.0;netstandard2.1;netcoreapp3.1;net5.0;net6.0;net6.0-windows;net7.0;net7.0-windows;net8.0;net8.0-windows</TargetFrameworks>
+ <TargetFrameworks>net45;net461;netstandard2.0;netstandard2.1;netcoreapp3.1;net5.0;net6.0;net6.0-windows;net7.0;net7.0-windows;net8.0;net8.0-windows</TargetFrameworks>
<AssemblyName>Stardust</AssemblyName>
<AssemblyTitle>星尘分布式服务核心</AssemblyTitle>
<Description>星尘,分布式服务框架。节点管理,监控中心,配置中心,发布中心,注册中心</Description>
<Company>新生命开发团队</Company>
<Copyright>©2002-2024 NewLife</Copyright>
- <VersionPrefix>3.0</VersionPrefix>
+ <VersionPrefix>3.1</VersionPrefix>
<VersionSuffix>$([System.DateTime]::Now.ToString(`yyyy.MMdd`))</VersionSuffix>
<Version>$(VersionPrefix).$(VersionSuffix)</Version>
<FileVersion>$(Version)</FileVersion>
@@ -112,13 +112,10 @@
</ItemGroup>
<ItemGroup>
- <PackageReference Include="NewLife.Remoting" Version="3.0.2024.902" />
+ <PackageReference Include="NewLife.Remoting" Version="3.1.2024.914-beta0002" />
</ItemGroup>
- <ItemGroup Condition="'$(TargetFramework)'!='net40'">
- <PackageReference Include="NewLife.Core" Version="10.10.2024.902" />
- </ItemGroup>
- <ItemGroup Condition="'$(TargetFramework)'=='net40'">
- <PackageReference Include="NewLife.Core" Version="10.10.2024.0801-net40" />
+ <ItemGroup>
+ <PackageReference Include="NewLife.Core" Version="11.0.2024.916-beta1549" />
</ItemGroup>
</Project>
diff --git a/StarGateway/Proxy/HttpReverseProxy.cs b/StarGateway/Proxy/HttpReverseProxy.cs
index 91df8b5..4fe5039 100644
--- a/StarGateway/Proxy/HttpReverseProxy.cs
+++ b/StarGateway/Proxy/HttpReverseProxy.cs
@@ -1,8 +1,6 @@
-using System;
-using System.IO;
-using NewLife;
+using NewLife;
+using NewLife.Http;
using NewLife.Net;
-using StarGateway.Http;
namespace StarGateway.Proxy
{
@@ -72,19 +70,19 @@ namespace StarGateway.Proxy
// 请求头
var request = new HttpRequest();
- if (request.Read(e.Packet))
+ if (request.Parse(e.Packet))
{
e.Message = request;
- // 解码请求头,准备修改细节
- request.DecodeHeaders();
+ //// 解码请求头,准备修改细节
+ //request.DecodeHeaders();
- if (OnRequest(request, e))
- {
- // 重新生成Http请求头
- request.EncodeHeaders();
- e.Packet = request.ToPacket();
- }
+ //if (OnRequest(request, e))
+ //{
+ // // 重新生成Http请求头
+ // request.EncodeHeaders();
+ // e.Packet = request.ToPacket();
+ //}
//var uri = new NetUri(NetType.Http, RawHost, Session.Local.Port);
WriteDebugLog(LocalUri + "");
@@ -98,12 +96,12 @@ namespace StarGateway.Proxy
// 修改Host
var host = request.Headers["Host"];
- LocalUri = new Uri($"http://{host}:{Session.Local.Port}{request.Uri}");
+ LocalUri = new Uri($"http://{host}:{Session.Local.Port}{request.RequestUri}");
host = GetHost(host);
if (host.IsNullOrEmpty()) return false;
- RemoteUri = new Uri($"http://{host}:{RemoteServerUri.Port}{request.Uri}");
+ RemoteUri = new Uri($"http://{host}:{RemoteServerUri.Port}{request.RequestUri}");
request.Headers["Host"] = host;
diff --git a/StarGateway/Proxy/ProxySession.cs b/StarGateway/Proxy/ProxySession.cs
index ce77c39..f7b3d0c 100644
--- a/StarGateway/Proxy/ProxySession.cs
+++ b/StarGateway/Proxy/ProxySession.cs
@@ -195,7 +195,7 @@ namespace StarGateway.Proxy
#region 发送
/// <summary>发送数据</summary>
/// <param name="pk">缓冲区</param>
- public virtual Int32 SendRemote(Packet pk)
+ public virtual Int32 SendRemote(IPacket pk)
{
try
{
diff --git a/StarGateway/StarGateway.csproj b/StarGateway/StarGateway.csproj
index 2c39507..247e790 100644
--- a/StarGateway/StarGateway.csproj
+++ b/StarGateway/StarGateway.csproj
@@ -28,8 +28,16 @@
</PropertyGroup>
<ItemGroup>
+ <Compile Remove="Http\HttpRequest.cs" />
+ </ItemGroup>
+
+ <ItemGroup>
<ProjectReference Include="..\Stardust.Data\Stardust.Data.csproj" />
<ProjectReference Include="..\Stardust\Stardust.csproj" />
</ItemGroup>
+ <ItemGroup>
+ <Folder Include="Http\" />
+ </ItemGroup>
+
</Project>
diff --git a/Test/Program.cs b/Test/Program.cs
index b78bc67..9566b85 100644
--- a/Test/Program.cs
+++ b/Test/Program.cs
@@ -7,6 +7,7 @@ using System.Net;
using System.Net.Sockets;
using System.Threading;
using NewLife;
+using NewLife.Data;
using NewLife.IO;
using NewLife.Log;
using NewLife.Messaging;
@@ -57,7 +58,7 @@ class Program
// Thread.Sleep(1000);
//}
- await io.Put("aa.txt", "学无先后达者为师!".GetBytes());
+ await io.Put("aa.txt", (ArrayPacket)"学无先后达者为师!".GetBytes());
var rs = await io.Get("aa.txt");
XTrace.WriteLine(rs.Data.ToStr());
@@ -157,7 +158,7 @@ class Program
writer.Write(0);
var msg = new DefaultMessage();
- msg.Payload = ms.ToArray();
+ msg.Payload = (ArrayPacket)ms.ToArray();
var buf = msg.ToPacket().ToArray();
XTrace.WriteLine(buf.ToHex());
diff --git a/Test/Test.csproj b/Test/Test.csproj
index f45a0fb..1107307 100644
--- a/Test/Test.csproj
+++ b/Test/Test.csproj
@@ -30,7 +30,7 @@
<ItemGroup>
<PackageReference Include="Microsoft.Win32.SystemEvents" Version="8.0.0" />
- <PackageReference Include="NewLife.Core" Version="10.10.2024.902" />
+ <PackageReference Include="NewLife.Core" Version="11.0.2024.916-beta1549" />
<PackageReference Include="SSH.NET" Version="2024.1.0" />
</ItemGroup>